akka.stream.stage

Class GraphStage<S extends Shape>

java.lang.Object

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

akka.stream.stage.GraphStage<S>

All Implemented Interfaces:

Graph<S,NotUsed>

Direct Known Subclasses:

ActorRefBackpressureSinkStage, Balance, Batch, Broadcast, ByteStringParser, Collect, Concat, CoupledTerminationBidi, Deserializer, EmptySource$, Expand, FlattenMerge, Fold, FoldAsync, GraphStages.FutureSource, GraphStages.MaterializedValueSource, GraphStages.SimpleLinearGraphStage, GraphStages.SingleSource, GroupBy, Grouped, GroupedWithin, InboundHandshake, InboundQuarantineCheck, InboundTestStage, IncomingConnectionStage, Interleave, JavaStreamSource, Map, MapAsync, MapAsyncUnordered, Merge, MergePreferred, MergeSorted, OrElse, OutboundHandshake, OutboundTestStage, Partition, PrefixAndTail, Scan, ScanAsync, Sliding, Split, StatefulMapConcat, SubSink, SubSource, SystemMessageAcker, SystemMessageDelivery, Timers.IdleInject, Timers.IdleTimeoutBidi, Unfold, UnfoldAsync, UnfoldResourceSource, UnfoldResourceSourceAsync, UnzipWith10, UnzipWith11, UnzipWith12, UnzipWith13, UnzipWith14, UnzipWith15, UnzipWith16, UnzipWith17, UnzipWith18, UnzipWith19, UnzipWith2, UnzipWith20, UnzipWith3, UnzipWith4, UnzipWith5, UnzipWith6, UnzipWith7, UnzipWith8, UnzipWith9, ZipWith10, ZipWith11, ZipWith12, ZipWith13, ZipWith14, ZipWith15, ZipWith16, ZipWith17, ZipWith18, ZipWith19, ZipWith2, ZipWith20, 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 stage. 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.

Constructor Summary

Constructors

Constructor and Description
GraphStage()

Method Summary

Modifier and Type	Method and Description
abstract GraphStageLogic	createLogic(Attributes inheritedAttributes)
scala.Tuple2<GraphStageLogic,NotUsed>	createLogicAndMaterializedValue(Attributes inheritedAttributes)

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

initialAttributes, module, 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, named, shape

Constructor Detail

GraphStage

public GraphStage()

Method Detail

createLogicAndMaterializedValue

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

Specified by:

createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<S extends Shape,NotUsed>

createLogic

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

Throws:

java.lang.Exception