Package energy.eddie.regionconnector.de.eta.providers

Class DeRawDataProvider

java.lang.Object

energy.eddie.regionconnector.de.eta.providers.DeRawDataProvider

All Implemented Interfaces:

RawDataProvider, AutoCloseable

@Component
public class DeRawDataProvider
extends Object
implements RawDataProvider

Provider for raw data messages from the DE-ETA region connector. This implementation subscribes to the ValidatedHistoricalDataStream and converts each validated historical data payload to a RawDataMessage.

Constructor Summary

Constructors

Constructor	Description
DeRawDataProvider(ValidatedHistoricalDataStream stream)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DeRawDataProvider

public DeRawDataProvider(ValidatedHistoricalDataStream stream)

Method Details

getRawDataStream

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

Description copied from interface: RawDataProvider

Stream of RawDataMessages produced by this region connector.

Specified by:

getRawDataStream in interface RawDataProvider

Returns:

RawDataMessage stream.

close

public void close()

Description copied from interface: RawDataProvider

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

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RawDataProvider