Package energy.eddie.regionconnector.aiida.provider.agnostic

Class AiidaRawDataProvider

java.lang.Object

energy.eddie.regionconnector.aiida.provider.agnostic.AiidaRawDataProvider

All Implemented Interfaces:

RawDataProvider, AutoCloseable

@Component
public class AiidaRawDataProvider
extends Object
implements RawDataProvider

Constructor Summary

Constructors

Constructor	Description
AiidaRawDataProvider(IdentifiableStreams streams)

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

AiidaRawDataProvider

public AiidaRawDataProvider(IdentifiableStreams streams)

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