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:

AbstractStage.PushPullGraphStageWithMaterializedValue, AeronSink, AeronSource, BroadcastHub, ConnectionSourceStage, Decoder, Encoder, GraphStage, GraphStages.IgnoreSink$, GraphStages.TickSource, HeadOptionStage, InboundControlJunction, InputStreamSinkStage, KillSwitches.UniqueBidiKillSwitchStage$, KillSwitches.UniqueKillSwitchStage$, LastOptionStage, LazySink, LazySource, MergeHub, OutboundControlJunction, OutgoingConnectionStage, OutputStreamSourceStage, QueueSink, QueueSource, SendQueue, SeqStage, TestSinkStage, TestSourceStage

public abstract class GraphStageWithMaterializedValue<S extends Shape,M>
extends java.lang.Object
implements Graph<S,M>

Constructor Summary

Constructors

Constructor and Description
GraphStageWithMaterializedValue()

Method Summary

Modifier and Type	Method and Description
abstract scala.Tuple2<GraphStageLogic,M>	createLogicAndMaterializedValue(Attributes inheritedAttributes)
protected Attributes	initialAttributes()
StreamLayout.Module	module() 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, named, shape

Constructor Detail

GraphStageWithMaterializedValue

public GraphStageWithMaterializedValue()

Method Detail

createLogicAndMaterializedValue

public abstract scala.Tuple2<GraphStageLogic,M> createLogicAndMaterializedValue(Attributes inheritedAttributes)
                                                                         throws java.lang.Exception

Throws:

java.lang.Exception

initialAttributes

protected Attributes initialAttributes()

module

public final StreamLayout.Module module()

Description copied from interface: Graph

INTERNAL API.

Every materializable element must be backed by a stream layout module

Specified by:

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