public class GraphStages
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
GraphStages.Detacher<T>
INTERNAL API
|
static class |
GraphStages.FutureSource<T> |
static class |
GraphStages.Identity$ |
static class |
GraphStages.IgnoreSink$
INTERNAL API
Discards all received elements.
|
static class |
GraphStages.MaterializedValueSource<T>
INTERNAL API.
|
static class |
GraphStages.SimpleLinearGraphStage<T>
INTERNAL API
|
static class |
GraphStages.SingleSource<T> |
static class |
GraphStages.TickSource<T> |
Constructor and Description |
---|
GraphStages() |
Modifier and Type | Method and 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.
|
public static <T> GraphStages.SimpleLinearGraphStage<T> identity()
public static <T> GraphStage<FlowShape<T,T>> detacher()
public static <T> GraphStageWithMaterializedValue<FlowShape<T,T>,scala.concurrent.Future<Done>> terminationWatcher()
public static <T> GraphStageWithMaterializedValue<FlowShape<T,T>,FlowMonitor<T>> monitor()
public static <T> Graph<UniformFanInShape<T,T>,NotUsed> withDetachedInputs(GraphStage<UniformFanInShape<T,T>> stage)
Fusing graphs that have cycles involving FanIn stages might lead to deadlocks if demand is not carefully managed.
This means that FanIn stages need to early pull every relevant input on startup. This can either be implemented inside the stage itself, or this method can be used, which adds a detacher stage to every input.
stage
- (undocumented)