Package akka.stream.stage

Class AbstractGraphStageWithMaterializedValue<S extends Shape,M>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<S,M>

akka.stream.stage.AbstractGraphStageWithMaterializedValue<S,M>

All Implemented Interfaces:

Graph<S,M>

public abstract class AbstractGraphStageWithMaterializedValue<S extends Shape,M>
extends GraphStageWithMaterializedValue<S,M>

Java API: A GraphStage represents a reusable graph stream processing operator.

Extend this AbstractGraphStageWithMaterializedValue if you want to provide a materialized value, represented by the type parameter M. If your GraphStage does not need to provide a materialized value you can instead extend GraphStage which materializes a NotUsed value.

A GraphStage consists of a Shape which describes its input and output ports and a factory function that creates a GraphStageLogic which implements the processing logic that ties the ports together.

See also GraphStageWithMaterializedValue for Scala 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
AbstractGraphStageWithMaterializedValue()

Method Summary

Modifier and Type	Method	Description
scala.Tuple2<GraphStageLogic,M>	createLogicAndMaterializedValue(Attributes inheritedAttributes)
abstract Pair<GraphStageLogic,M>	createLogicAndMaterializedValuePair(Attributes inheritedAttributes)

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

initialAttributes, withAttributes

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

Constructor Detail

AbstractGraphStageWithMaterializedValue

public AbstractGraphStageWithMaterializedValue()

Method Detail

createLogicAndMaterializedValue

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

Specified by:

createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<S extends Shape,M>

Throws:

java.lang.Exception

createLogicAndMaterializedValuePair

public abstract Pair<GraphStageLogic,M> createLogicAndMaterializedValuePair(Attributes inheritedAttributes)
                                                                           throws java.lang.Exception

Throws:

java.lang.Exception