Class ConditionalTerminateInput
Input handler that terminates the state upon receiving completion if the given condition holds at that time.The stage fails upon receiving a failure.
Implements
Inherited Members
Namespace: Akka.Streams.Stage
Assembly: Akka.Streams.dll
Syntax
public class ConditionalTerminateInput : InHandler, IInHandler
Constructors
| Edit this page View SourceConditionalTerminateInput(Func<bool>)
TBD
Declaration
public ConditionalTerminateInput(Func<bool> predicate)
Parameters
Type | Name | Description |
---|---|---|
Func<bool> | predicate | TBD |
Methods
| Edit this page View SourceOnPush()
TBD
Declaration
public override void OnPush()
Overrides
| Edit this page View SourceOnUpstreamFinish()
TBD
Declaration
public override void OnUpstreamFinish()