Class JsonRawDataProvider

java.lang.Object
energy.eddie.regionconnector.shared.agnostic.JsonRawDataProvider

public class JsonRawDataProvider extends Object
  • Constructor Details

    • JsonRawDataProvider

      @SafeVarargs public JsonRawDataProvider(String regionConnector, tools.jackson.databind.ObjectMapper objectMapper, reactor.core.publisher.Flux<? extends IdentifiablePayload<?,?>>... fluxes)
  • Method Details

    • getRawDataStream

      public reactor.core.publisher.Flux<RawDataMessage> getRawDataStream()