Class JavaFlowSupport.Flow$

  • Enclosing class:
    JavaFlowSupport

    public static class JavaFlowSupport.Flow$
    extends java.lang.Object
    Flow factories operating with java.util.concurrent.Flow.* interfaces.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      static JavaFlowSupport.Flow$ MODULE$
      Static reference to the singleton instance of this Scala object.
    • Constructor Summary

      Constructors 
      Constructor Description
      Flow$()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <I,​O>
      Flow<I,​O,​NotUsed>
      fromProcessor​(scala.Function0<java.util.concurrent.Flow.Processor<I,​O>> processorFactory)
      Creates a Flow from a Reactive Streams Processor
      <I,​O,​M>
      Flow<I,​O,​M>
      fromProcessorMat​(scala.Function0<scala.Tuple2<java.util.concurrent.Flow.Processor<I,​O>,​M>> processorFactory)
      Creates a Flow from a Reactive Streams Flow.Processor and returns a materialized value.
      <In,​Out,​Mat>
      RunnableGraph<java.util.concurrent.Flow.Processor<In,​Out>>
      toProcessor​(Flow<In,​Out,​Mat> self)
      Converts this Flow to a RunnableGraph that materializes to a Reactive Streams Flow.Processor which implements the operations encapsulated by this Flow.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • MODULE$

        public static final JavaFlowSupport.Flow$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • Flow$

        public Flow$()
    • Method Detail

      • fromProcessor

        public <I,​O> Flow<I,​O,​NotUsed> fromProcessor​(scala.Function0<java.util.concurrent.Flow.Processor<I,​O>> processorFactory)
        Creates a Flow from a Reactive Streams Processor
      • fromProcessorMat

        public <I,​O,​M> Flow<I,​O,​M> fromProcessorMat​(scala.Function0<scala.Tuple2<java.util.concurrent.Flow.Processor<I,​O>,​M>> processorFactory)
        Creates a Flow from a Reactive Streams Flow.Processor and returns a materialized value.
      • toProcessor

        public <In,​Out,​Mat> RunnableGraph<java.util.concurrent.Flow.Processor<In,​Out>> toProcessor​(Flow<In,​Out,​Mat> self)
        Converts this Flow to a RunnableGraph that materializes to a Reactive Streams Flow.Processor which implements the operations encapsulated by this Flow. Every materialization results in a new Processor instance, i.e. the returned RunnableGraph is reusable.

        Returns:
        A RunnableGraph that materializes to a Processor when run() is called on it.