akka.stream

Interface Graph<S extends Shape,M>

All Known Implementing Classes:

AbstractStage.PushPullGraphStage, AbstractStage.PushPullGraphStageWithMaterializedValue, ActorRefBackpressureSinkStage, AeronSink, AeronSource, Balance, Batch, BidiFlow, BidiFlow, Broadcast, BroadcastHub, Buffer, ByteStringParser, Collect, Concat, ConnectionSourceStage, CoupledTerminationBidi, Decoder, DeflateDecompressor, DeflateDecompressorBase, Delay, Deserializer, Drop, DropWhile, DropWithin, EmptySource$, Encoder, Expand, Filter, FlattenMerge, Flow, Flow, Fold, FoldAsync, Fusing.FusedGraph, GraphApply.GraphImpl, GraphStage, GraphStages.Detacher, GraphStages.FutureSource, GraphStages.Identity$, GraphStages.IgnoreSink$, GraphStages.MaterializedValueSource, GraphStages.SimpleLinearGraphStage, GraphStages.SingleSource, GraphStages.TickSource, GraphStageWithMaterializedValue, GroupBy, Grouped, GroupedWithin, GzipDecompressor, HeadOptionStage, InboundControlJunction, InboundHandshake, InboundQuarantineCheck, InboundTestStage, IncomingConnectionStage, InputStreamSinkStage, Interleave, Intersperse, JavaStreamSource, KillSwitches.UniqueBidiKillSwitchStage$, KillSwitches.UniqueKillSwitchStage$, LastOptionStage, LazySink, LazySource, LimitWeighted, Log, Map, MapAsync, MapAsyncUnordered, MapError, Merge, MergeHub, MergePreferred, MergeSorted, OrElse, OutboundControlJunction, OutboundHandshake, OutboundTestStage, OutgoingConnectionStage, OutputStreamSourceStage, Partition, PrefixAndTail, QueueSink, QueueSource, Recover, RecoverWith, Reduce, RunnableGraph, RunnableGraph, Scan, ScanAsync, SendQueue, SeqStage, Sink, Sink, Sliding, Source, Source, Split, Stages.SymbolicGraphStage, StatefulMapConcat, SubSink, SubSource, SystemMessageAcker, SystemMessageDelivery, Take, TakeWhile, TakeWithin, TestSinkStage, TestSourceStage, Throttle, Timed.StartTimed, Timed.StopTimed, Timed.TimedInterval, Timers.BackpressureTimeout, Timers.Completion, Timers.DelayInitial, Timers.Idle, Timers.IdleInject, Timers.IdleTimeoutBidi, Timers.Initial, Unfold, UnfoldAsync, UnfoldResourceSource, UnfoldResourceSourceAsync, Unzip, UnzipWith10, UnzipWith11, UnzipWith12, UnzipWith13, UnzipWith14, UnzipWith15, UnzipWith16, UnzipWith17, UnzipWith18, UnzipWith19, UnzipWith2, UnzipWith20, UnzipWith3, UnzipWith4, UnzipWith5, UnzipWith6, UnzipWith7, UnzipWith8, UnzipWith9, Zip, ZipN, ZipWith10, ZipWith11, ZipWith12, ZipWith13, ZipWith14, ZipWith15, ZipWith16, ZipWith17, ZipWith18, ZipWith19, ZipWith2, ZipWith20, ZipWith3, ZipWith4, ZipWith5, ZipWith6, ZipWith7, ZipWith8, ZipWith9, ZipWithN

public interface Graph<S extends Shape,M>

Method Summary

Modifier and Type	Method and Description
Graph<S,M>	addAttributes(Attributes attr)
Graph<S,M>	async() Put an asynchronous boundary around this Graph
StreamLayout.Module	module() INTERNAL API.
Graph<S,M>	named(java.lang.String name)
S	shape() The shape of a graph is all that is externally visible: its inlets and outlets.
Graph<S,M>	withAttributes(Attributes attr)

Method Detail

shape

S shape()

The shape of a graph is all that is externally visible: its inlets and outlets.

Returns:

(undocumented)

module

StreamLayout.Module module()

INTERNAL API.

Every materializable element must be backed by a stream layout module

Returns:

(undocumented)

withAttributes

Graph<S,M> withAttributes(Attributes attr)

named

Graph<S,M> named(java.lang.String name)

async

Graph<S,M> async()

Put an asynchronous boundary around this Graph

Returns:

(undocumented)

addAttributes

Graph<S,M> addAttributes(Attributes attr)