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)
INTERNAL API.
-
-
-
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)
INTERNAL API.Fusing graphs that have cycles involving FanIn operators might lead to deadlocks if demand is not carefully managed.
This means that FanIn operators need to early pull every relevant input on startup. This can either be implemented inside the operator itself, or this method can be used, which adds a detacher operator to every input.
-
-