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
,GraphStage
,KillSwitches.UniqueBidiKillSwitchStage$
,KillSwitches.UniqueKillSwitchStage$
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)
protected Attributes
initialAttributes()
Graph<S,M>
withAttributes(Attributes attr)
Replace the attributes of thisFlow
with the given ones.-
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, getAttributes, named, shape
-
-
-
-
Method Detail
-
createLogicAndMaterializedValue
public abstract scala.Tuple2<GraphStageLogic,M> createLogicAndMaterializedValue(Attributes inheritedAttributes) throws java.lang.Exception
- Throws:
java.lang.Exception
-
initialAttributes
protected Attributes initialAttributes()
-
withAttributes
public final Graph<S,M> withAttributes(Attributes attr)
Description copied from interface:Graph
Replace the attributes of thisFlow
with the given ones. If this Flow is a composite of multiple graphs, new attributes on the composite will be less specific than attributes set directly on the individual graphs of the composite.- Specified by:
withAttributes
in interfaceGraph<S extends Shape,M>
-
-