Class OutHandler

Collection of callbacks for an output port of a GraphStage<TShape>

Inheritance

Object

OutHandler

ConditionalTerminateOutput

EagerTerminateOutput

GraphStageLogic.LambdaOutHandler

IgnoreTerminateOutput

Implements

IOutHandler

Inherited Members

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 OutHandler : IOutHandler

Methods

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

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()

Implements

IOutHandler

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)