Class ConditionalTerminateOutput

Output handler that terminates the state upon receiving completion if the given condition holds at that time.The stage fails upon receiving a failure.

Inheritance

object

OutHandler

ConditionalTerminateOutput

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 class ConditionalTerminateOutput : OutHandler, IOutHandler

Constructors

ConditionalTerminateOutput(Func<bool>)

TBD

Declaration

public ConditionalTerminateOutput(Func<bool> predicate)

Parameters

Type	Name	Description
Func<bool>	predicate	TBD

Methods

OnDownstreamFinish(Exception)

TBD

Declaration

public override void OnDownstreamFinish(Exception cause)

Parameters

Type	Name	Description
Exception	cause

Overrides

OutHandler.OnDownstreamFinish(Exception)

OnPull()

TBD

Declaration

public override void OnPull()

Overrides

OutHandler.OnPull()

Implements

IOutHandler

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)