Package akka.stream.impl.fusing
Class GraphStages$
- java.lang.Object
-
- akka.stream.impl.fusing.GraphStages$
-
public class GraphStages$ extends java.lang.Object
INTERNAL API
-
-
Field Summary
Fields Modifier and Type Field Description static GraphStages$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description GraphStages$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> GraphStage<FlowShape<T,T>>
detacher()
<T> GraphStages.SimpleLinearGraphStage<T>
identity()
<T> GraphStageWithMaterializedValue<FlowShape<T,T>,FlowMonitor<T>>
monitor()
<T> GraphStageWithMaterializedValue<FlowShape<T,T>,scala.concurrent.Future<Done>>
terminationWatcher()
<T> Graph<UniformFanInShape<T,T>,NotUsed>
withDetachedInputs(GraphStage<UniformFanInShape<T,T>> stage)
-
-
-
Field Detail
-
MODULE$
public static final GraphStages$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
identity
public <T> GraphStages.SimpleLinearGraphStage<T> identity()
-
detacher
public <T> GraphStage<FlowShape<T,T>> detacher()
-
terminationWatcher
public <T> GraphStageWithMaterializedValue<FlowShape<T,T>,scala.concurrent.Future<Done>> terminationWatcher()
-
monitor
public <T> GraphStageWithMaterializedValue<FlowShape<T,T>,FlowMonitor<T>> monitor()
-
withDetachedInputs
public <T> Graph<UniformFanInShape<T,T>,NotUsed> withDetachedInputs(GraphStage<UniformFanInShape<T,T>> stage)
-
-