Class DocumentStreams
java.lang.Object
energy.eddie.regionconnector.simulation.providers.DocumentStreams
- All Implemented Interfaces:
ConnectionStatusMessageProvider,PermissionMarketDocumentProvider,ValidatedHistoricalDataEnvelopeProvider,AutoCloseable
@Component
public class DocumentStreams
extends Object
implements ValidatedHistoricalDataEnvelopeProvider, ConnectionStatusMessageProvider, PermissionMarketDocumentProvider
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()Emit a complete signal on the Flow in this method.reactor.core.publisher.Flux<ConnectionStatusMessage> Data stream of all connection status updates created by this region connector.reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope> Data stream of all PermissionMarketDocument updates created by this region connector.reactor.core.publisher.Flux<SimulatedMeterReading> reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope> Data stream of all ValidatedHistoricalDataEnvelopes created by this region connector.voidpublish(ConnectionStatusMessage connectionStatusMessage) voidpublish(energy.eddie.cim.v0_82.pmd.PermissionEnvelope permissionEnvelope) voidpublish(SimulatedMeterReading document)
-
Constructor Details
-
DocumentStreams
-
-
Method Details
-
publish
-
publish
-
publish
public void publish(energy.eddie.cim.v0_82.pmd.PermissionEnvelope permissionEnvelope) -
getValidatedHistoricalDataMarketDocumentsStream
public reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope> getValidatedHistoricalDataMarketDocumentsStream()Description copied from interface:ValidatedHistoricalDataEnvelopeProviderData stream of all ValidatedHistoricalDataEnvelopes created by this region connector.- Specified by:
getValidatedHistoricalDataMarketDocumentsStreamin interfaceValidatedHistoricalDataEnvelopeProvider- Returns:
- ValidatedHistoricalDataEnvelope stream
-
close
public void close()Description copied from interface:ValidatedHistoricalDataEnvelopeProviderEmit a complete signal on the Flow in this method.- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceConnectionStatusMessageProvider- Specified by:
closein interfaceValidatedHistoricalDataEnvelopeProvider
-
getConnectionStatusMessageStream
Description copied from interface:ConnectionStatusMessageProviderData stream of all connection status updates created by this region connector.- Specified by:
getConnectionStatusMessageStreamin interfaceConnectionStatusMessageProvider- Returns:
- connection status message stream
-
getPermissionMarketDocumentStream
public reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope> getPermissionMarketDocumentStream()Description copied from interface:PermissionMarketDocumentProviderData stream of all PermissionMarketDocument updates created by this region connector. The PermissionMarketDocument will contain the new state of the permission in the process- Specified by:
getPermissionMarketDocumentStreamin interfacePermissionMarketDocumentProvider- Returns:
- PermissionMarketDocument stream that can be consumed only once
-
getSimulatedMeterReadingStream
-