Package 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, DuplicateHandshakeReq, EmptySource$, Expand, FailedSource, FlattenMerge, Fold, FoldAsync, GraphStages.FutureSource, GraphStages.SimpleLinearGraphStage, GraphStages.SingleSource, GroupBy, Grouped, GroupedWeightedWithin, InboundHandshake, InboundQuarantineCheck, InboundTestStage, IncomingConnectionStage, Interleave, JavaStreamSource, Map, MapAsync, MapAsyncUnordered, Merge, MergeLatest, MergePreferred, MergePrioritized, MergeSorted, OrElse, OutboundHandshake, OutboundTestStage, Partition, PrefixAndTail, RestartWithBackoffFlow, RestartWithBackoffSink, RestartWithBackoffSource, 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, UnzipWith21, UnzipWith22, UnzipWith3, UnzipWith4, UnzipWith5, UnzipWith6, UnzipWith7, UnzipWith8, UnzipWith9, WireTap, 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.

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 akka.stream.stage.GraphStageWithMaterializedValue

createLogicAndMaterializedValue, initialAttributes, traversalBuilder, 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, 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>