Package akka.stream.stage
Class GraphStage<S extends Shape>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<S>
-
- Direct Known Subclasses:
ActorRefBackpressureSinkStage
,ActorRefSinkStage
,AllPersistenceIdsStage
,Balance
,Batch
,Broadcast
,ByteStringParser
,Collect
,Concat
,CoupledTerminationBidi
,Deserializer
,DuplicateHandshakeReq
,EmptySource$
,EventsByPersistenceIdStage
,EventsByTagStage
,Expand
,FailedSource
,FlattenMerge
,Fold
,FoldAsync
,GraphStages.FutureSource
,GraphStages.SimpleLinearGraphStage
,GraphStages.SingleSource
,GroupBy
,Grouped
,GroupedWeightedWithin
,InboundHandshake
,InboundQuarantineCheck
,InboundTestStage
,IncomingConnectionStage
,Interleave
,JavaStreamSource
,Map
,MapAsync
,MapAsyncUnordered
,Merge
,MergeLatest
,MergePreferred
,MergePrioritized
,MergeSorted
,OrElse
,OutboundHandshake
,OutboundTestStage
,Partition
,PrefixAndTail
,RestartWithBackoffFlow
,RestartWithBackoffSink
,RestartWithBackoffSource
,RetryFlowCoordinator
,Scan
,ScanAsync
,Sliding
,Split
,StatefulMapConcat
,SubSink
,SubSource
,SystemMessageAcker
,SystemMessageDelivery
,Timers.IdleInject
,Timers.IdleTimeoutBidi
,Unfold
,UnfoldAsync
,UnfoldResourceSource
,UnfoldResourceSourceAsync
,UnzipWith10
,UnzipWith11
,UnzipWith12
,UnzipWith13
,UnzipWith14
,UnzipWith15
,UnzipWith16
,UnzipWith17
,UnzipWith18
,UnzipWith19
,UnzipWith2
,UnzipWith20
,UnzipWith21
,UnzipWith22
,UnzipWith3
,UnzipWith4
,UnzipWith5
,UnzipWith6
,UnzipWith7
,UnzipWith8
,UnzipWith9
,WireTap
,ZipLatestWith10
,ZipLatestWith11
,ZipLatestWith12
,ZipLatestWith13
,ZipLatestWith14
,ZipLatestWith15
,ZipLatestWith16
,ZipLatestWith17
,ZipLatestWith18
,ZipLatestWith19
,ZipLatestWith2
,ZipLatestWith20
,ZipLatestWith21
,ZipLatestWith22
,ZipLatestWith3
,ZipLatestWith4
,ZipLatestWith5
,ZipLatestWith6
,ZipLatestWith7
,ZipLatestWith8
,ZipLatestWith9
,ZipWith10
,ZipWith11
,ZipWith12
,ZipWith13
,ZipWith14
,ZipWith15
,ZipWith16
,ZipWith17
,ZipWith18
,ZipWith19
,ZipWith2
,ZipWith20
,ZipWith21
,ZipWith22
,ZipWith3
,ZipWith4
,ZipWith5
,ZipWith6
,ZipWith7
,ZipWith8
,ZipWith9
,ZipWithN
public abstract class GraphStage<S extends Shape> extends GraphStageWithMaterializedValue<S,NotUsed>
A GraphStage represents a reusable graph stream processing operator.A GraphStage consists of a
Shape
which describes its input and output ports and a factory function that creates aGraphStageLogic
which implements the processing logic that ties the ports together.
-
-
Constructor Summary
Constructors Constructor Description GraphStage()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract GraphStageLogic
createLogic(Attributes inheritedAttributes)
scala.Tuple2<GraphStageLogic,NotUsed>
createLogicAndMaterializedValue(Attributes inheritedAttributes)
-
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, initialAttributes, traversalBuilder, withAttributes
-
-
-
-
Method Detail
-
createLogic
public abstract GraphStageLogic createLogic(Attributes inheritedAttributes) throws java.lang.Exception
- Throws:
java.lang.Exception
-
createLogicAndMaterializedValue
public final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)
- Specified by:
createLogicAndMaterializedValue
in classGraphStageWithMaterializedValue<S extends Shape,NotUsed>
-
-