Class JsonRawDataProvider
java.lang.Object
energy.eddie.regionconnector.shared.agnostic.JsonRawDataProvider
- All Implemented Interfaces:
RawDataProvider,AutoCloseable
-
Constructor Summary
ConstructorsConstructorDescriptionJsonRawDataProvider(String regionConnector, com.fasterxml.jackson.databind.ObjectMapper objectMapper, reactor.core.publisher.Flux<? extends IdentifiablePayload<?, ?>>... fluxes) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()Emit a complete signal on the Flow returned byRawDataProvider.getRawDataStream()in this method.reactor.core.publisher.Flux<RawDataMessage> Stream ofRawDataMessages produced by this region connector.
-
Constructor Details
-
JsonRawDataProvider
@SafeVarargs public JsonRawDataProvider(String regionConnector, com.fasterxml.jackson.databind.ObjectMapper objectMapper, reactor.core.publisher.Flux<? extends IdentifiablePayload<?, ?>>... fluxes)
-
-
Method Details
-
getRawDataStream
Description copied from interface:RawDataProviderStream ofRawDataMessages produced by this region connector.- Specified by:
getRawDataStreamin interfaceRawDataProvider- Returns:
- RawDataMessage stream.
-
close
public void close()Description copied from interface:RawDataProviderEmit a complete signal on the Flow returned byRawDataProvider.getRawDataStream()in this method.- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceRawDataProvider
-