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, BroadcastHub, ConnectionSourceStage, Decoder, Encoder, FileOutputStage, FileSource, GraphStage, GraphStages.FutureFlattenSource, GraphStages.IgnoreSink$, GraphStages.TickSource, HeadOptionStage, InboundControlJunction, InputStreamSinkStage, InputStreamSource, KillSwitches.UniqueBidiKillSwitchStage$, KillSwitches.UniqueKillSwitchStage$, LazyFlow, 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>

Grants access to the materializer before preStart of the graph stage logic is invoked.

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
GraphStageWithMaterializedValue()

Method Summary

Modifier and Type	Method	Description
abstract scala.Tuple2<GraphStageLogic,M>	createLogicAndMaterializedValue(Attributes inheritedAttributes)
scala.Tuple2<GraphStageLogic,M>	createLogicAndMaterializedValue(Attributes inheritedAttributes, Materializer materializer)
protected Attributes	initialAttributes()
TraversalBuilder	traversalBuilder()	INTERNAL API
Graph<S,M>	withAttributes(Attributes attr)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named, shape

Constructor Detail

GraphStageWithMaterializedValue

public GraphStageWithMaterializedValue()

Method Detail

createLogicAndMaterializedValue

public scala.Tuple2<GraphStageLogic,M> createLogicAndMaterializedValue(Attributes inheritedAttributes,
                                                                             Materializer materializer)

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 interface Graph<S extends Shape,M>

Returns:

(undocumented)

withAttributes

public final Graph<S,M> withAttributes(Attributes attr)

Specified by:

withAttributes in interface Graph<S extends Shape,M>