Search Results for

    Show / Hide Table of Contents

    Interface IDetachedContext

    Passed to the callback methods of DetachedStage<TIn, TOut>.

    HoldDownstream() and HoldUpstream() stops execution and at the same time putting the stage in a holding state. If the stage is in a holding state it contains one absorbed signal, therefore in this state the only possible command to call is PushAndPull(object) which results in two events making the balance right again: 1 hold + 1 external event = 2 external event

    Inherited Members
    IContext.IsFinishing
    IContext.PushAndFinish(object)
    IContext.Push(object)
    IContext.Pull()
    IContext.Finish()
    IContext.Finish(Exception)
    IContext.Fail(Exception)
    IContext.AbsorbTermination()
    ILifecycleContext.Materializer
    ILifecycleContext.Attributes
    Namespace: Akka.Streams.Stage
    Assembly: Akka.Streams.dll
    Syntax
    public interface IDetachedContext : IContext, ILifecycleContext

    Properties

    | Edit this page View Source

    IsHoldingBoth

    This returns true when HoldDownstream() and HoldUpstream() has been used and it is reset to false after PushAndPull(object).

    Declaration
    bool IsHoldingBoth { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsHoldingDownstream

    TBD

    Declaration
    bool IsHoldingDownstream { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsHoldingUpstream

    TBD

    Declaration
    bool IsHoldingUpstream { get; }
    Property Value
    Type Description
    bool

    Methods

    | Edit this page View Source

    HoldDownstream()

    TBD

    Declaration
    IDownstreamDirective HoldDownstream()
    Returns
    Type Description
    IDownstreamDirective

    TBD

    | Edit this page View Source

    HoldDownstreamAndPull()

    TBD

    Declaration
    IDownstreamDirective HoldDownstreamAndPull()
    Returns
    Type Description
    IDownstreamDirective

    TBD

    | Edit this page View Source

    HoldUpstream()

    TBD

    Declaration
    IUpstreamDirective HoldUpstream()
    Returns
    Type Description
    IUpstreamDirective

    TBD

    | Edit this page View Source

    HoldUpstreamAndPush(object)

    TBD

    Declaration
    IUpstreamDirective HoldUpstreamAndPush(object element)
    Parameters
    Type Name Description
    object element

    TBD

    Returns
    Type Description
    IUpstreamDirective

    TBD

    | Edit this page View Source

    PushAndPull(object)

    TBD

    Declaration
    FreeDirective PushAndPull(object element)
    Parameters
    Type Name Description
    object element

    TBD

    Returns
    Type Description
    FreeDirective

    TBD

    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