Interface IAsyncContext

This kind of context is available to IAsyncContext<TOut, TExt>. It implements the same interface as for IDetachedContext with the addition of being able to obtain AsyncCallback objects that allow the registration of asynchronous notifications.

Inherited Members

IDetachedContext.IsHoldingBoth

IDetachedContext.IsHoldingUpstream

IDetachedContext.IsHoldingDownstream

IDetachedContext.PushAndPull(object)

IDetachedContext.HoldUpstream()

IDetachedContext.HoldUpstreamAndPush(object)

IDetachedContext.HoldDownstream()

IDetachedContext.HoldDownstreamAndPull()

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 IAsyncContext : IDetachedContext, IContext, ILifecycleContext

Methods

GetAsyncCallback()

Obtain a callback object that can be used asynchronously to re-enter the current IAsyncContext<TOut, TExt> with an asynchronous notification. After the notification has been invoked, eventually Akka.Streams.Implementation.Fusing.GraphInterpreter.OnAsyncInput will be called with the given data item.

This object can be cached and reused within the same IAsyncContext<TOut, TExt>.

Declaration

AsyncCallback GetAsyncCallback()

Returns

Type	Description
AsyncCallback	TBD

Ignore()

In response to an asynchronous notification an IAsyncContext<TOut, TExt> may choose to neither push nor pull nor terminate, which is represented as this directive.

Declaration

IAsyncDirective Ignore()

Returns

Type	Description
IAsyncDirective	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)