Class EdaAccountingPointEnvelopeProvider
java.lang.Object
energy.eddie.regionconnector.at.eda.provider.v0_82.EdaAccountingPointEnvelopeProvider
- All Implemented Interfaces:
AccountingPointEnvelopeProvider,AutoCloseable
@Component
public class EdaAccountingPointEnvelopeProvider
extends Object
implements AccountingPointEnvelopeProvider
This class is for processing incoming master data by mapping it to
AccountingPointEnvelope-
Constructor Summary
ConstructorsConstructorDescriptionEdaAccountingPointEnvelopeProvider(IdentifiableStreams streams, IntermediateAccountingPointMarketDocumentFactory factory) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()Emit a complete signal on the Flow in this method.reactor.core.publisher.Flux<energy.eddie.cim.v0_82.ap.AccountingPointEnvelope> Data stream of all EddieValidatedHistoricalDataMarketDocument created by this region connector.
-
Constructor Details
-
EdaAccountingPointEnvelopeProvider
public EdaAccountingPointEnvelopeProvider(IdentifiableStreams streams, IntermediateAccountingPointMarketDocumentFactory factory)
-
-
Method Details
-
getAccountingPointEnvelopeFlux
public reactor.core.publisher.Flux<energy.eddie.cim.v0_82.ap.AccountingPointEnvelope> getAccountingPointEnvelopeFlux()Description copied from interface:AccountingPointEnvelopeProviderData stream of all EddieValidatedHistoricalDataMarketDocument created by this region connector.- Specified by:
getAccountingPointEnvelopeFluxin interfaceAccountingPointEnvelopeProvider- Returns:
- EddieValidatedHistoricalDataMarketDocument stream
-
close
Description copied from interface:AccountingPointEnvelopeProviderEmit a complete signal on the Flow in this method.- Specified by:
closein interfaceAccountingPointEnvelopeProvider- Specified by:
closein interfaceAutoCloseable- Throws:
Exception
-