Package akka.stream

Interface Graph<S extends Shape,M>

All Known Subinterfaces:

StreamLayout.AtomicModule<S,M>

All Known Implementing Classes:

AbstractGraphStageWithMaterializedValue, ActorRefBackpressureSinkStage, ActorRefBackpressureSource, ActorRefSinkStage, ActorRefSource, AeronSink, AeronSource, AllPersistenceIdsStage, Balance, Batch, BidiFlow, BidiFlow, Broadcast, BroadcastHub, Buffer, ByteStringParser, CancelSink, Collect, Concat, ConnectionSourceStage, CoupledTerminationBidi, Decoder, DeflateDecompressor, DeflateDecompressorBase, Delay, Deserializer, Drop, DropWhile, DropWithin, DuplicateHandshakeReq, EmptySource$, Encoder, EventsByPersistenceIdStage, EventsByTagStage, Expand, FailedSource, FanoutPublisherSink, FileOutputStage, FileSource, Filter, FixedSizePartitionHub, FlattenMerge, Flow, Flow, FlowWithContext, FlowWithContext, Fold, FoldAsync, GenericGraph, GenericGraphWithChangedAttributes, GraphDelegate, GraphStage, GraphStageModule, GraphStages.Detacher, GraphStages.FutureFlattenSource, GraphStages.FutureSource, GraphStages.IgnoreSink$, GraphStages.SimpleLinearGraphStage, GraphStages.SingleSource, GraphStages.TickSource, GraphStageWithMaterializedValue, GroupBy, Grouped, GroupedWeightedWithin, GzipDecompressor, HeadOptionStage, InboundControlJunction, InboundHandshake, InboundQuarantineCheck, InboundTestStage, IncomingConnectionStage, InputStreamSinkStage, InputStreamSource, Interleave, Intersperse, JavaStreamSource, KillSwitches.UniqueBidiKillSwitchStage$, KillSwitches.UniqueKillSwitchStage$, LazyFlow, LazySink, LazySource, LimitWeighted, Log, Map, MapAsync, MapAsyncUnordered, MapError, MaybeSource$, Merge, MergeHub, MergeLatest, MergePreferred, MergePrioritized, MergeSorted, OrElse, OutboundControlJunction, OutboundHandshake, OutboundTestStage, OutgoingConnectionStage, OutputStreamGraphStage, OutputStreamSourceStage, Partition, PartitionHub, PrefixAndTail, ProcessorModule, PublisherSink, PublisherSource, QueueSink, QueueSource, Recover, RecoverWith, Reduce, RestartWithBackoffFlow, RestartWithBackoffSink, RestartWithBackoffSource, RetryFlowCoordinator, RunnableGraph, RunnableGraph, Scan, ScanAsync, SendQueue, SeqStage, SetupFlowStage, SetupSinkStage, SetupSourceStage, Sink, Sink, SinkModule, SinkRefStageImpl, Sliding, Source, Source, SourceModule, SourceRefStageImpl, SourceWithContext, SourceWithContext, Split, StatefulMapConcat, StreamTestKit.ProbeSink, StreamTestKit.ProbeSource, SubscriberSink, SubscriberSource, SubSink, SubSource, SystemMessageAcker, SystemMessageDelivery, Take, TakeLastStage, TakeWhile, TakeWithin, TcpFraming, TestSinkStage, TestSourceStage, Throttle, Timers.BackpressureTimeout, Timers.Completion, Timers.DelayInitial, Timers.Idle, Timers.IdleInject, Timers.IdleTimeoutBidi, Timers.Initial, TlsModule, Unfold, UnfoldAsync, UnfoldResourceSource, UnfoldResourceSourceAsync, Unzip, UnzipWith10, UnzipWith11, UnzipWith12, UnzipWith13, UnzipWith14, UnzipWith15, UnzipWith16, UnzipWith17, UnzipWith18, UnzipWith19, UnzipWith2, UnzipWith20, UnzipWith21, UnzipWith22, UnzipWith3, UnzipWith4, UnzipWith5, UnzipWith6, UnzipWith7, UnzipWith8, UnzipWith9, Watch, WireTap, Zip, ZipLatest, ZipLatestWith10, ZipLatestWith11, ZipLatestWith12, ZipLatestWith13, ZipLatestWith14, ZipLatestWith15, ZipLatestWith16, ZipLatestWith17, ZipLatestWith18, ZipLatestWith19, ZipLatestWith2, ZipLatestWith20, ZipLatestWith21, ZipLatestWith22, ZipLatestWith3, ZipLatestWith4, ZipLatestWith5, ZipLatestWith6, ZipLatestWith7, ZipLatestWith8, ZipLatestWith9, ZipN, ZipWith10, ZipWith11, ZipWith12, ZipWith13, ZipWith14, ZipWith15, ZipWith16, ZipWith17, ZipWith18, ZipWith19, ZipWith2, ZipWith20, ZipWith21, ZipWith22, ZipWith3, ZipWith4, ZipWith5, ZipWith6, ZipWith7, ZipWith8, ZipWith9, ZipWithN

public interface Graph<S extends Shape,M>

Type-level accessor for the shape parameter of this graph.

Method Summary

Modifier and Type	Method	Description
Graph<S,M>	addAttributes(Attributes attr)	Add the given attributes to this Graph.
Graph<S,M>	async()	Put an asynchronous boundary around this Graph
Graph<S,M>	async(java.lang.String dispatcher)	Put an asynchronous boundary around this Graph
Graph<S,M>	async(java.lang.String dispatcher, int inputBufferSize)	Put an asynchronous boundary around this Graph
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.
TraversalBuilder	traversalBuilder()	INTERNAL API.
Graph<S,M>	withAttributes(Attributes attr)

Method Detail

addAttributes

Graph<S,M> addAttributes(Attributes attr)

Add the given attributes to this Graph. If the specific attribute was already present on this graph this means the added attribute will be more specific than the existing one. If this Source is a composite of multiple graphs, new attributes on the composite will be less specific than attributes set directly on the individual graphs of the composite.

Parameters:

attr - (undocumented)

Returns:

(undocumented)

async

Graph<S,M> async()

Put an asynchronous boundary around this Graph

Returns:

(undocumented)

async

Graph<S,M> async(java.lang.String dispatcher)

Put an asynchronous boundary around this Graph

Parameters:

dispatcher - Run the graph on this dispatcher

Returns:

(undocumented)

async

Graph<S,M> async(java.lang.String dispatcher,
                       int inputBufferSize)

Put an asynchronous boundary around this Graph

Parameters:

dispatcher - Run the graph on this dispatcher

inputBufferSize - Set the input buffer to this size for the graph

Returns:

(undocumented)

named

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

shape

S shape()

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

Returns:

(undocumented)

traversalBuilder

TraversalBuilder traversalBuilder()

INTERNAL API.

Every materializable element must be backed by a stream layout module

Returns:

(undocumented)

withAttributes

Graph<S,M> withAttributes(Attributes attr)