Namespace Akka.Streams.Implementation
Classes
ActorMaterializerImpl
TBD
ActorPublisher
TBD
ActorSubscription
TBD
ActorSubscription<T>
TBD
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.
BatchingInputBuffer
TBD
CancelingSubscriber<T>
A subscriber who calls Reactive.Streams.ISubscription.Cancel() directly from OnSubscribe(ISubscription) and ignores all other callbacks.
CompositeModule
TBD
CopiedModule
TBD
DistinctRetainingMultiReaderBuffer<T>
EmptyModule
TBD
EmptyPublisher<T>
TBD
EmptySource<TOut>
INTERNAL API
EnumerableActorName
Generator of sequentially numbered actor names.
ExposedPublisherReceive
TBD
ExtendedActorMaterializer
ExtendedActorMaterializer used by subtypes which materializer using GraphInterpreterShell
FanIn
TBD
FanIn<T>
TBD
FlowNameCounter
TBD
FusedModule
TBD
IgnorableMaterializedValueComposites
TBD
InputBunch
TBD
LazySource
API for the Akka.Streams.Implementation.LazySource<TOut, TMat>
Module
TBD
NormalShutdownException
TBD
NothingToReadException
TBD
OutputBunch<T>
TBD
ReactiveStreamsCompliance
TBD
RetainingMultiReaderBuffer<T>
SignalThrewException
TBD
SimpleOutputs
TBD
StreamLayout
TBD
StreamLayout.Atomic
TBD
StreamLayout.Combine
TBD
StreamLayout.Ignore
TBD
StreamLayout.Transform
TBD
StreamSupervisor
TBD
StreamSupervisor.Children
TBD
StreamSupervisor.GetChildren
TBD
StreamSupervisor.Materialize
TBD
StreamSupervisor.PrintDebugDump
TBD
StreamSupervisor.StopChildren
TBD
StreamSupervisor.StoppedChildren
TBD
StructuralInfoModule
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).
SubFlowImpl<TIn, TOut, TMat, TClosed>
TBD
SubFusingActorMaterializerImpl
TBD
SubReceive
TBD
SubscriptionTimeoutException
TBD
TransferState
TBD
Structs
FanIn.OnComplete
TBD
FanIn.OnError
TBD
FanIn.OnNext
TBD
FanIn.OnSubscribe
TBD
FanIn<T>.SubInput
TBD
TransferPhase
TBD
Interfaces
IActorPublisher
TBD
IActorSubscription
TBD
ICursor
TBD
ICursors
TBD
IMergeBack<TIn, TMat>
TBD
IModule
TBD
IPump
TBD
ISpecViolation
TBD
StreamLayout.IMaterializedValueNode
TBD