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$
static class
GraphStages.SimpleLinearGraphStage<T>
static 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)
-
-
-
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)
-
-