Class IdentifiableStreams

java.lang.Object
energy.eddie.regionconnector.aiida.streams.IdentifiableStreams

@Component public class IdentifiableStreams extends Object
  • Constructor Details

    • IdentifiableStreams

      public IdentifiableStreams(reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope> nearRealTimeDataSink, reactor.core.publisher.Sinks.Many<RawDataMessage> rawDataMessageSink)
  • Method Details

    • nearRealTimeDataFlux

      public reactor.core.publisher.Flux<energy.eddie.cim.v1_04.rtd.RTDEnvelope> nearRealTimeDataFlux()
    • rawDataMessageFlux

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