Package org.apache.pekko.stream.stage

Class AbstractGraphStageWithMaterializedValue<S extends Shape,M>

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,M>

org.apache.pekko.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 org.apache.pekko.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
AbstractGraphStageWithMaterializedValue()

Method Summary

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

Methods inherited from class org.apache.pekko.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 org.apache.pekko.stream.Graph

addAttributes, async, async, async, getAttributes, named, shape

Constructor Details

AbstractGraphStageWithMaterializedValue

public AbstractGraphStageWithMaterializedValue()

Method Details

createLogicAndMaterializedValue

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

Specified by:

createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<S extends Shape,M>

Throws:

Exception

createLogicAndMaterializedValuePair

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

Throws:

Exception