Package akka.stream.stage
Class GraphStageWithMaterializedValue<S extends Shape,M>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,M>
-
- All Implemented Interfaces:
Graph<S,M>
- Direct Known Subclasses:
AbstractGraphStageWithMaterializedValue
,ActorRefBackpressureSource
,ActorRefSource
,AeronSink
,AeronSource
,BoundedSourceQueueStage
,BroadcastHub
,ConnectionSourceStage
,Decoder
,Encoder
,FastForwardingFilter
,FileOutputStage
,FileSource
,FlatMapPrefix
,FutureFlow
,GraphStage
,GraphStages.FutureFlattenSource
,GraphStages.IgnoreSink$
,GraphStages.TickSource
,HeadOptionStage
,InboundControlJunction
,InputStreamSinkStage
,InputStreamSource
,KillSwitches.UniqueBidiKillSwitchStage$
,KillSwitches.UniqueKillSwitchStage$
,LazySink
,LazySource
,MaybeSource$
,MergeHub
,OutboundControlJunction
,OutgoingConnectionStage
,OutputStreamGraphStage
,OutputStreamSourceStage
,PartitionHub
,QueueSink
,QueueSource
,SendQueue
,SeqStage
,SetupFlowStage
,SetupSinkStage
,SetupSourceStage
,SinkRefStageImpl
,SourceRefStageImpl
,TakeLastStage
,TestSinkStage
,TestSourceStage
public abstract class GraphStageWithMaterializedValue<S extends Shape,M> extends java.lang.Object implements Graph<S,M>
Scala API: A GraphStage represents a reusable graph stream processing operator.Extend this
GraphStageWithMaterializedValue
if you want to provide a materialized value, represented by the type parameterM
. If your GraphStage does not need to provide a materialized value you can instead extendeGraphStage
which materializes aNotUsed
value.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.See also
AbstractGraphStageWithMaterializedValue
for Java DSL for this operator.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.stream.Graph
Graph.GraphMapMatVal<S extends Shape,M>
-
-
Constructor Summary
Constructors Constructor Description GraphStageWithMaterializedValue()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract scala.Tuple2<GraphStageLogic,M>
createLogicAndMaterializedValue(Attributes inheritedAttributes)
scala.Tuple2<GraphStageLogic,M>
createLogicAndMaterializedValue(Attributes inheritedAttributes, Materializer materializer)
Grants access to the materializer before preStart of the graph stage logic is invoked.protected Attributes
initialAttributes()
TraversalBuilder
traversalBuilder()
INTERNAL APIGraph<S,M>
withAttributes(Attributes attr)
-
-
-
Method Detail
-
createLogicAndMaterializedValue
public scala.Tuple2<GraphStageLogic,M> createLogicAndMaterializedValue(Attributes inheritedAttributes, Materializer materializer)
Grants access to the materializer before preStart of the graph stage logic is invoked.INTERNAL API
-
createLogicAndMaterializedValue
public abstract scala.Tuple2<GraphStageLogic,M> createLogicAndMaterializedValue(Attributes inheritedAttributes) throws java.lang.Exception
- Throws:
java.lang.Exception
-
initialAttributes
protected Attributes initialAttributes()
-
traversalBuilder
public final TraversalBuilder traversalBuilder()
INTERNAL API- Specified by:
traversalBuilder
in interfaceGraph<S extends Shape,M>
-
withAttributes
public final Graph<S,M> withAttributes(Attributes attr)
- Specified by:
withAttributes
in interfaceGraph<S extends Shape,M>
-
-