Package energy.eddie.regionconnector.de.eta.providers

Class ValidatedHistoricalDataStream

java.lang.Object

energy.eddie.regionconnector.de.eta.providers.ValidatedHistoricalDataStream

All Implemented Interfaces:

AutoCloseable

@Component
public class ValidatedHistoricalDataStream
extends Object
implements AutoCloseable

Central stream for validated historical data from ETA Plus. This component manages the reactive stream of validated historical data AND is responsible for tracking the latest meter reading for fulfillment checks.

Constructor Summary

Constructors

Constructor	Description
ValidatedHistoricalDataStream(Outbox outbox)

Method Summary

Modifier and Type	Method	Description
void	close()
void	publish(DePermissionRequest permissionRequest, EtaPlusMeteredData data)	Publish validated historical data to the stream and update latest reading state.
reactor.core.publisher.Flux<IdentifiableValidatedHistoricalData>	validatedHistoricalData()	Get the flux of validated historical data.

Methods inherited from class java.lang.Object

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

Constructor Details

ValidatedHistoricalDataStream

public ValidatedHistoricalDataStream(Outbox outbox)

Method Details

validatedHistoricalData

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

Get the flux of validated historical data. Subscribers (like DeRawDataProvider) use this.

Returns:

the flux of identifiable validated historical data

publish

public void publish(DePermissionRequest permissionRequest,
 EtaPlusMeteredData data)

Publish validated historical data to the stream and update latest reading state.

Parameters:

permissionRequest - the permission request the data belongs to

data - the validated historical data from ETA Plus

close

public void close()

Specified by:

close in interface AutoCloseable