Interface IContext

Passed to the callback methods of PushPullStage<TIn, TOut> and StatefulStage<TIn, TOut>.

Inherited Members
Namespace: Akka.Streams.Stage
Assembly: Akka.Streams.dll
Syntax
public interface IContext : ILifecycleContext

Properties

| Edit this page View Source

IsFinishing

This returns true after AbsorbTermination() has been used.

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

Methods

| Edit this page View Source

AbsorbTermination()

Puts the stage in a finishing state so that final elements can be pushed from onPull.

Declaration
ITerminationDirective AbsorbTermination()
Returns
Type Description
ITerminationDirective

TBD
| Edit this page View Source

Fail(Exception)

Cancel upstreams and complete downstreams with failure.

Declaration
FreeDirective Fail(Exception cause)
Parameters
Type Name Description
Exception cause

TBD
Returns
Type Description
FreeDirective

TBD
| Edit this page View Source

Finish()

Cancel upstreams and complete downstreams successfully.

Declaration
FreeDirective Finish()
Returns
Type Description
FreeDirective

TBD
| Edit this page View Source

Finish(Exception)

Declaration
FreeDirective Finish(Exception cause)
Parameters
Type Name Description
Exception cause
Returns
Type Description
FreeDirective
| Edit this page View Source

Pull()

Request for more elements from upstreams.

Declaration
IUpstreamDirective Pull()
Returns
Type Description
IUpstreamDirective

TBD
| Edit this page View Source

Push(object)

Push one element to downstreams.

Declaration
IDownstreamDirective Push(object element)
Parameters
Type Name Description
object element

TBD
Returns
Type Description
IDownstreamDirective

TBD
| Edit this page View Source

PushAndFinish(object)

Push one element to downstream immediately followed by cancel of upstreams and complete of downstreams.

Declaration
IDownstreamDirective PushAndFinish(object element)
Parameters
Type Name Description
object element

TBD
Returns
Type Description
IDownstreamDirective

TBD

Extension Methods