Search Results for

    Show / Hide Table of Contents

    Class InAndOutGraphStageLogic

    A GraphStageLogic that implements IInHandler and IOutHandler.

    OnUpstreamFinish() calls CompleteStage()

    OnUpstreamFailure(Exception) calls FailStage(Exception)

    OnDownstreamFinish(Exception) calls CompleteStage()
    Inheritance
    object
    GraphStageLogic
    InAndOutGraphStageLogic
    Implements
    IStageLogging
    IInHandler
    IOutHandler
    Inherited Members
    GraphStageLogic.NoPromise
    GraphStageLogic.EagerTerminateInput
    GraphStageLogic.IgnoreTerminateInput
    GraphStageLogic.ConditionalTerminateInput(Func<bool>)
    GraphStageLogic.TotallyIgnorantInput
    GraphStageLogic.EagerTerminateOutput
    GraphStageLogic.IgnoreTerminateOutput
    GraphStageLogic.DoNothing
    GraphStageLogic.ConditionalTerminateOutput(Func<bool>)
    GraphStageLogic.InCount
    GraphStageLogic.OutCount
    GraphStageLogic.Materializer
    GraphStageLogic.SubFusingMaterializer
    GraphStageLogic.KeepGoingAfterAllPortsClosed
    GraphStageLogic.StageActor
    GraphStageLogic.LogSource
    GraphStageLogic.Log
    GraphStageLogic.SetHandler<T>(Inlet<T>, IInHandler)
    GraphStageLogic.SetHandler<T>(Inlet<T>, Action, Action, Action<Exception>)
    GraphStageLogic.GetHandler<T>(Inlet<T>)
    GraphStageLogic.SetHandler<T>(Outlet<T>, IOutHandler)
    GraphStageLogic.SetHandler<T>(Outlet<T>, Action, Action<Exception>)
    GraphStageLogic.SetHandler<TIn, TOut>(Inlet<TIn>, Outlet<TOut>, InAndOutGraphStageLogic)
    GraphStageLogic.SetHandlers<TIn, TOut>(Inlet<TIn>, Outlet<TOut>, InAndOutGraphStageLogic)
    GraphStageLogic.GetHandler<T>(Outlet<T>)
    GraphStageLogic.Pull<T>(Inlet<T>)
    GraphStageLogic.TryPull<T>(Inlet<T>)
    GraphStageLogic.Cancel<T>(Inlet<T>, Exception)
    GraphStageLogic.Cancel<T>(Inlet<T>)
    GraphStageLogic.Grab<T>(Inlet<T>)
    GraphStageLogic.HasBeenPulled<T>(Inlet<T>)
    GraphStageLogic.IsAvailable<T>(Inlet<T>)
    GraphStageLogic.IsClosed<T>(Inlet<T>)
    GraphStageLogic.Push<T>(Outlet<T>, T)
    GraphStageLogic.SetKeepGoing(bool)
    GraphStageLogic.Complete<T>(Outlet<T>)
    GraphStageLogic.Fail<T>(Outlet<T>, Exception)
    GraphStageLogic.CancelStage(Exception)
    GraphStageLogic.CompleteStage()
    GraphStageLogic.FailStage(Exception)
    GraphStageLogic.IsAvailable<T>(Outlet<T>)
    GraphStageLogic.IsClosed<T>(Outlet<T>)
    GraphStageLogic.ReadMany<T>(Inlet<T>, int, Action<IEnumerable<T>>, Action<IEnumerable<T>>)
    GraphStageLogic.Read<T>(Inlet<T>, Action<T>, Action)
    GraphStageLogic.AbortReading<T>(Inlet<T>)
    GraphStageLogic.EmitMultiple<T>(Outlet<T>, IEnumerable<T>, Action)
    GraphStageLogic.EmitMultiple<T>(Outlet<T>, IEnumerable<T>)
    GraphStageLogic.EmitMultiple<T>(Outlet<T>, IEnumerator<T>, Action)
    GraphStageLogic.EmitMultiple<T>(Outlet<T>, IEnumerator<T>)
    GraphStageLogic.Emit<T>(Outlet<T>, T, Action)
    GraphStageLogic.Emit<T>(Outlet<T>, T)
    GraphStageLogic.AbortEmitting<T>(Outlet<T>)
    GraphStageLogic.PassAlong<TOut, TIn>(Inlet<TIn>, Outlet<TOut>, bool, bool, bool)
    GraphStageLogic.GetAsyncCallback<T>(Action<T>)
    GraphStageLogic.GetTypedAsyncCallback<T>(Action<T>)
    GraphStageLogic.GetAsyncCallback(Action)
    GraphStageLogic.GetStageActor(StageActorRef.Receive)
    GraphStageLogic.StageActorName
    GraphStageLogic.BeforePreStart()
    GraphStageLogic.AfterPostStop()
    GraphStageLogic.PreStart()
    GraphStageLogic.PostStop()
    GraphStageLogic.CreateSubSinkInlet<T>(string)
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Streams.Stage
    Assembly: Akka.Streams.dll
    Syntax
    public abstract class InAndOutGraphStageLogic : GraphStageLogic, IStageLogging, IInHandler, IOutHandler

    Constructors

    | Edit this page View Source

    InAndOutGraphStageLogic(Shape)

    TBD

    Declaration
    protected InAndOutGraphStageLogic(Shape shape)
    Parameters
    Type Name Description
    Shape shape

    TBD

    | Edit this page View Source

    InAndOutGraphStageLogic(int, int)

    TBD

    Declaration
    protected InAndOutGraphStageLogic(int inCount, int outCount)
    Parameters
    Type Name Description
    int inCount

    TBD

    int outCount

    TBD

    Methods

    | Edit this page View Source

    OnDownstreamFinish(Exception)

    Called when the output port will no longer accept any new elements. After this callback no other callbacks will be called for this port.

    Declaration
    public virtual void OnDownstreamFinish(Exception cause)
    Parameters
    Type Name Description
    Exception cause
    | Edit this page View Source

    OnPull()

    Called when the output port has received a pull, and therefore ready to emit an element, i.e. Push<T>(Outlet<T>, T) is now allowed to be called on this port.

    Declaration
    public abstract void OnPull()
    | Edit this page View Source

    OnPush()

    Called when the input port has a new element available. The actual element can be retrieved via the Grab<T>(Inlet<T>) method.

    Declaration
    public abstract void OnPush()
    | Edit this page View Source

    OnUpstreamFailure(Exception)

    Called when the input port has failed. After this callback no other callbacks will be called for this port.

    Declaration
    public virtual void OnUpstreamFailure(Exception e)
    Parameters
    Type Name Description
    Exception e

    TBD

    | Edit this page View Source

    OnUpstreamFinish()

    Called when the input port is finished. After this callback no other callbacks will be called for this port.

    Declaration
    public virtual void OnUpstreamFinish()

    Implements

    IStageLogging
    IInHandler
    IOutHandler

    Extension Methods

    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    Extensions.AsInstanceOf<T>(object)
    In this article
    • githubEdit this page
    • View Source
    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