Package akka.stream.impl.fusing
Class GraphStages.SimpleLinearGraphStage<T>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<FlowShape<T,T>>
-
- akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage<T>
-
- Direct Known Subclasses:
Buffer,Delay,Drop,DropWhile,DropWithin,Filter,GraphStages.Detacher,Intersperse,LimitWeighted,Log,MapError,Recover,RecoverWith,Reduce,Take,TakeWhile,TakeWithin,Throttle,Timed.StartTimed,Timed.StopTimed,Timed.TimedInterval,Timers.BackpressureTimeout,Timers.Completion,Timers.DelayInitial,Timers.Idle,Timers.Initial,Watch
- Enclosing class:
- GraphStages
public abstract static class GraphStages.SimpleLinearGraphStage<T> extends GraphStage<FlowShape<T,T>>
-
-
Constructor Summary
Constructors Constructor Description SimpleLinearGraphStage()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Inlet<T>in()Outlet<T>out()FlowShape<T,T>shape()The shape of a graph is all that is externally visible: its inlets and outlets.-
Methods inherited from class akka.stream.stage.GraphStage
createLogic, createLogicAndMaterializedValue
-
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, initialAttributes, traversalBuilder, withAttributes
-
-