Package org.apache.pekko.stream.stage

Class GraphStage<S extends Shape>

java.lang.Object

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

org.apache.pekko.stream.stage.GraphStage<S>

All Implemented Interfaces:

Graph<S,NotUsed>

Direct Known Subclasses:

Balance, Broadcast, Concat, Interleave, Merge, MergeLatest, MergePreferred, MergePrioritized, MergeSequence, MergeSorted, Partition, RestartWithBackoffFlow, RestartWithBackoffSink, RestartWithBackoffSource, UnzipWith10, UnzipWith11, UnzipWith12, UnzipWith13, UnzipWith14, UnzipWith15, UnzipWith16, UnzipWith17, UnzipWith18, UnzipWith19, UnzipWith2, UnzipWith20, UnzipWith21, UnzipWith22, UnzipWith3, UnzipWith4, UnzipWith5, UnzipWith6, UnzipWith7, UnzipWith8, UnzipWith9, ZipLatestWith10, ZipLatestWith11, ZipLatestWith12, ZipLatestWith13, ZipLatestWith14, ZipLatestWith15, ZipLatestWith16, ZipLatestWith17, ZipLatestWith18, ZipLatestWith19, ZipLatestWith2, ZipLatestWith20, ZipLatestWith21, ZipLatestWith22, ZipLatestWith3, ZipLatestWith4, ZipLatestWith5, ZipLatestWith6, ZipLatestWith7, ZipLatestWith8, ZipLatestWith9, ZipWith10, ZipWith11, ZipWith12, ZipWith13, ZipWith14, ZipWith15, ZipWith16, ZipWith17, ZipWith18, ZipWith19, ZipWith2, ZipWith20, ZipWith21, ZipWith22, ZipWith3, ZipWith4, ZipWith5, ZipWith6, ZipWith7, ZipWith8, ZipWith9, ZipWithN

public abstract class GraphStage<S extends Shape>
extends GraphStageWithMaterializedValue<S,NotUsed>

A GraphStage represents a reusable graph stream processing operator.

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.

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
GraphStage()

Method Summary

Modifier and Type	Method	Description
abstract GraphStageLogic	createLogic(Attributes inheritedAttributes)
scala.Tuple2<GraphStageLogic,NotUsed>	createLogicAndMaterializedValue(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 Detail

GraphStage

public GraphStage()

Method Detail

createLogic

public abstract GraphStageLogic createLogic(Attributes inheritedAttributes)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

createLogicAndMaterializedValue

public final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)

Specified by:

createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<S extends Shape,NotUsed>