Class IdentifiableDataStreams
java.lang.Object
energy.eddie.regionconnector.be.fluvius.streams.IdentifiableDataStreams
- All Implemented Interfaces:
AutoCloseable
-
Constructor Summary
ConstructorsConstructorDescription -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()reactor.core.publisher.Flux<IdentifiableMeteringData> voidpublish(FluviusPermissionRequest permissionRequest, GetEnergyResponseModelApiDataResponse payload)
-
Constructor Details
-
IdentifiableDataStreams
-
IdentifiableDataStreams
public IdentifiableDataStreams()
-
-
Method Details
-
publish
public void publish(FluviusPermissionRequest permissionRequest, GetEnergyResponseModelApiDataResponse payload) -
getMeteringData
-
close
public void close()- Specified by:
closein interfaceAutoCloseable
-