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
-
-