Package energy.eddie.regionconnector.cds.providers

Class IdentifiableDataStreams

java.lang.Object

energy.eddie.regionconnector.cds.providers.IdentifiableDataStreams

All Implemented Interfaces:

AutoCloseable

@Component
public class IdentifiableDataStreams
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
IdentifiableDataStreams()
IdentifiableDataStreams(DataNeedMapper dataNeedMapper, EmptyDataFilter emptyDataFilter)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<IdentifiableAccountingPointData>	accountingPointData()
void	close()
void	publishAccountingPointData(CdsPermissionRequest pr, List<energy.eddie.regionconnector.cds.openapi.model.AccountsEndpoint200ResponseAllOfAccountsInner> accounts, List<energy.eddie.regionconnector.cds.openapi.model.ServiceContractEndpoint200ResponseAllOfServiceContractsInner> serviceContracts, List<energy.eddie.regionconnector.cds.openapi.model.ServicePointEndpoint200ResponseAllOfServicePointsInner> servicePoints, List<energy.eddie.regionconnector.cds.openapi.model.MeterDeviceEndpoint200ResponseAllOfMeterDevicesInner> meterDevices)
void	publishValidatedHistoricalData(CdsPermissionRequest pr, List<energy.eddie.regionconnector.cds.openapi.model.AccountsEndpoint200ResponseAllOfAccountsInner> accounts, List<energy.eddie.regionconnector.cds.openapi.model.ServiceContractEndpoint200ResponseAllOfServiceContractsInner> serviceContracts, List<energy.eddie.regionconnector.cds.openapi.model.ServicePointEndpoint200ResponseAllOfServicePointsInner> servicePoints, List<energy.eddie.regionconnector.cds.openapi.model.MeterDeviceEndpoint200ResponseAllOfMeterDevicesInner> meterDevices, List<energy.eddie.regionconnector.cds.openapi.model.UsageSegmentEndpoint200ResponseAllOfUsageSegmentsInner> usageSegments)
reactor.core.publisher.Flux<IdentifiableValidatedHistoricalData>	validatedHistoricalData()

Methods inherited from class java.lang.Object

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

Constructor Details

IdentifiableDataStreams

@Autowired
public IdentifiableDataStreams(DataNeedMapper dataNeedMapper,
 EmptyDataFilter emptyDataFilter)

IdentifiableDataStreams

public IdentifiableDataStreams()

Method Details

validatedHistoricalData

public reactor.core.publisher.Flux<IdentifiableValidatedHistoricalData> validatedHistoricalData()

accountingPointData

public reactor.core.publisher.Flux<IdentifiableAccountingPointData> accountingPointData()

close

public void close()

Specified by:

close in interface AutoCloseable

publishValidatedHistoricalData

public void publishValidatedHistoricalData(CdsPermissionRequest pr,
 List<energy.eddie.regionconnector.cds.openapi.model.AccountsEndpoint200ResponseAllOfAccountsInner> accounts,
 List<energy.eddie.regionconnector.cds.openapi.model.ServiceContractEndpoint200ResponseAllOfServiceContractsInner> serviceContracts,
 List<energy.eddie.regionconnector.cds.openapi.model.ServicePointEndpoint200ResponseAllOfServicePointsInner> servicePoints,
 List<energy.eddie.regionconnector.cds.openapi.model.MeterDeviceEndpoint200ResponseAllOfMeterDevicesInner> meterDevices,
 List<energy.eddie.regionconnector.cds.openapi.model.UsageSegmentEndpoint200ResponseAllOfUsageSegmentsInner> usageSegments)

publishAccountingPointData

public void publishAccountingPointData(CdsPermissionRequest pr,
 List<energy.eddie.regionconnector.cds.openapi.model.AccountsEndpoint200ResponseAllOfAccountsInner> accounts,
 List<energy.eddie.regionconnector.cds.openapi.model.ServiceContractEndpoint200ResponseAllOfServiceContractsInner> serviceContracts,
 List<energy.eddie.regionconnector.cds.openapi.model.ServicePointEndpoint200ResponseAllOfServicePointsInner> servicePoints,
 List<energy.eddie.regionconnector.cds.openapi.model.MeterDeviceEndpoint200ResponseAllOfMeterDevicesInner> meterDevices)