Namespace Akka.Streams.Implementation

Classes

ActorSubscriptionWithCursor<TIn>

TBD

AtomicModule

This is the only extension point for the sealed type hierarchy: composition (i.e. the module tree) is managed strictly within this file, only leaf nodes may be declared elsewhere.

CancelingSubscriber<T>

A subscriber who calls Reactive.Streams.ISubscription.Cancel() directly from OnSubscribe(ISubscription) and ignores all other callbacks.

DistinctRetainingMultiReaderBuffer<T>

EnumerableActorName

Generator of sequentially numbered actor names.

ExtendedActorMaterializer

ExtendedActorMaterializer used by subtypes which materializer using GraphInterpreterShell

IgnorableMaterializedValueComposites

TBD

LazySource

API for the Akka.Streams.Implementation.LazySource<TOut, TMat>

StreamSupervisor.PrintDebugDump

TBD

StreamSupervisor.StoppedChildren

TBD

When fusing a IGraph<TShape> a part of the internal stage wirings are hidden within Akka.Streams.Implementation.Fusing.GraphAssembly objects that are optimized for high-speed execution. This structural information bundle contains the wirings in a more accessible form, allowing traversal from port to upstream or downstream port and from there to the owning module (or graph vertex).

Namespace Akka.Streams.Implementation

Classes

Structs

Interfaces