Package energy.eddie.regionconnector.at.eda.provider

Class IdentifiableStreams

java.lang.Object

energy.eddie.regionconnector.at.eda.provider.IdentifiableStreams

@Component
public class IdentifiableStreams
extends Object

Constructor Summary

Constructors

Constructor	Description
IdentifiableStreams(org.springframework.beans.factory.ObjectProvider<UnaryOperator<IdentifiableConsumptionRecord>> duplicateDataFilter, EdaAdapter edaAdapter)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<IdentifiableConsumptionRecord>	consumptionRecordStream()
reactor.core.publisher.Flux<IdentifiableMasterData>	masterDataStream()

Methods inherited from class java.lang.Object

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

Constructor Details

IdentifiableStreams

public IdentifiableStreams(org.springframework.beans.factory.ObjectProvider<UnaryOperator<IdentifiableConsumptionRecord>> duplicateDataFilter,
 EdaAdapter edaAdapter)

Method Details

consumptionRecordStream

public reactor.core.publisher.Flux<IdentifiableConsumptionRecord> consumptionRecordStream()

masterDataStream

public reactor.core.publisher.Flux<IdentifiableMasterData> masterDataStream()