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
Namespace: Akka.Streams.Stage
Assembly: Akka.Streams.dll
Syntax
public interface IDetachedContext : IContext, ILifecycleContext

Properties

| Improve this Doc 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
Boolean
| Improve this Doc View Source

IsHoldingDownstream

TBD

Declaration
bool IsHoldingDownstream { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

IsHoldingUpstream

TBD

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

Methods

| Improve this Doc View Source

HoldDownstream()

TBD

Declaration
IDownstreamDirective HoldDownstream()
Returns
Type Description
IDownstreamDirective

TBD
| Improve this Doc View Source

HoldDownstreamAndPull()

TBD

Declaration
IDownstreamDirective HoldDownstreamAndPull()
Returns
Type Description
IDownstreamDirective

TBD
| Improve this Doc View Source

HoldUpstream()

TBD

Declaration
IUpstreamDirective HoldUpstream()
Returns
Type Description
IUpstreamDirective

TBD
| Improve this Doc View Source

HoldUpstreamAndPush(Object)

TBD

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

TBD
Returns
Type Description
IUpstreamDirective

TBD
| Improve this Doc View Source

PushAndPull(Object)

TBD

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

TBD
Returns
Type Description
FreeDirective

TBD

Extension Methods