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

Class AccountingPointDataStream

java.lang.Object

energy.eddie.regionconnector.de.eta.providers.AccountingPointDataStream

All Implemented Interfaces:

AutoCloseable

@Component
public class AccountingPointDataStream
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
AccountingPointDataStream()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<IdentifiableAccountingPointData>	accountingPointData()	Get the flux of accounting point data.
void	close()
void	publish(DePermissionRequest permissionRequest, EtaPlusAccountingPointData data)	Publish a chunk of accounting point data.

Methods inherited from class java.lang.Object

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

Constructor Details

AccountingPointDataStream

public AccountingPointDataStream()

Method Details

accountingPointData

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

Get the flux of accounting point data.

Returns:

flux of identifiable accounting point data

publish

public void publish(DePermissionRequest permissionRequest,
 EtaPlusAccountingPointData data)

Publish a chunk of accounting point data.

Parameters:

permissionRequest - the permission request associated with this data

data - the accounting point data from the MDA

close

public void close()

Specified by:

close in interface AutoCloseable