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
GraphStageWithMaterializedValueif 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 extendeGraphStagewhich materializes aNotUsedvalue.A GraphStage consists of a
Shapewhich describes its input and output ports and a factory function that creates aGraphStageLogicwhich implements the processing logic that ties the ports together.See also
AbstractGraphStageWithMaterializedValuefor 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 AttributesinitialAttributes()Graph<S,M>withAttributes(Attributes attr)Replace the attributes of thisFlowwith 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:GraphReplace the attributes of thisFlowwith 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:
withAttributesin interfaceGraph<S extends Shape,M>
-
-