Package energy.eddie.regionconnector.us.green.button.providers.agnostic

Class UsRawDataProvider

java.lang.Object

energy.eddie.regionconnector.us.green.button.providers.agnostic.UsRawDataProvider

All Implemented Interfaces:

RawDataProvider, AutoCloseable

@Component
public class UsRawDataProvider
extends Object
implements RawDataProvider

Constructor Summary

Constructors

Constructor	Description
UsRawDataProvider(PublishService publishService)

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

UsRawDataProvider

public UsRawDataProvider(PublishService publishService)

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