Class AbstractGraphStageWithMaterializedValue<S extends Shape,​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.