Package energy.eddie.api.agnostic

Interface RawDataProvider

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

AiidaRawDataProvider, DeRawDataProvider, EdaRawDataProvider, EnergyDataService, JsonRawDataProvider, UsRawDataProvider

public interface RawDataProvider
extends AutoCloseable

Used to extend a RegionConnector by making a Flux of RawDataMessages available.

Method Summary

Modifier and Type	Method	Description
void	close()	Emit a complete signal on the Flow returned by getRawDataStream() in this method.
reactor.core.publisher.Flux<RawDataMessage>	getRawDataStream()	Stream of RawDataMessages produced by this region connector.

Method Details

getRawDataStream

reactor.core.publisher.Flux<RawDataMessage> getRawDataStream()

Stream of RawDataMessages produced by this region connector.

Returns:

RawDataMessage stream.

close

void close()

Emit a complete signal on the Flow returned by getRawDataStream() in this method.

Specified by:

close in interface AutoCloseable