Package akka.stream.impl.fusing
Class GraphStages
- java.lang.Object
-
- akka.stream.impl.fusing.GraphStages
-
public class GraphStages extends java.lang.Object
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
GraphStages.Detacher<T>
INTERNAL APIstatic class
GraphStages.FutureFlattenSource<T,M>
static class
GraphStages.FutureSource<T>
static class
GraphStages.IgnoreSink$
INTERNAL API Discards all received elements.static class
GraphStages.SimpleLinearGraphStage<T>
INTERNAL APIstatic class
GraphStages.SingleSource<T>
static class
GraphStages.TickSource<T>
-
Constructor Summary
Constructors Constructor Description GraphStages()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> GraphStage<FlowShape<T,T>>
detacher()
static <T> GraphStages.SimpleLinearGraphStage<T>
identity()
static <T> GraphStageWithMaterializedValue<FlowShape<T,T>,FlowMonitor<T>>
monitor()
static <T> GraphStageWithMaterializedValue<FlowShape<T,T>,scala.concurrent.Future<Done>>
terminationWatcher()
static <T> Graph<UniformFanInShape<T,T>,NotUsed>
withDetachedInputs(GraphStage<UniformFanInShape<T,T>> stage)
INTERNAL API.
-
-
-
Method Detail
-
identity
public static <T> GraphStages.SimpleLinearGraphStage<T> identity()
-
detacher
public static <T> GraphStage<FlowShape<T,T>> detacher()
-
terminationWatcher
public static <T> GraphStageWithMaterializedValue<FlowShape<T,T>,scala.concurrent.Future<Done>> terminationWatcher()
-
monitor
public static <T> GraphStageWithMaterializedValue<FlowShape<T,T>,FlowMonitor<T>> monitor()
-
withDetachedInputs
public static <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.
-
-