Search Results for

    Show / Hide Table of Contents

    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

    In This Article
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET