Package akka.stream.scaladsl
Class JavaFlowSupport.Flow$
- java.lang.Object
-
- akka.stream.scaladsl.JavaFlowSupport.Flow$
-
- Enclosing class:
- JavaFlowSupport
public static class JavaFlowSupport.Flow$ extends java.lang.Object
Flow
factories operating withjava.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 StreamsProcessor
<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 StreamsFlow.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 aRunnableGraph
that materializes to a Reactive StreamsFlow.Processor
which implements the operations encapsulated by this Flow.
-
-
-
Field Detail
-
MODULE$
public static final JavaFlowSupport.Flow$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
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 StreamsProcessor
-
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 StreamsFlow.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 aRunnableGraph
that materializes to a Reactive StreamsFlow.Processor
which implements the operations encapsulated by this Flow. Every materialization results in a new Processor instance, i.e. the returnedRunnableGraph
is reusable.- Returns:
- A
RunnableGraph
that materializes to a Processor when run() is called on it.
-
-