Package org.apache.pekko.stream.stage

Class GraphStageLogic.ConditionalTerminateInput

java.lang.Object

org.apache.pekko.stream.stage.GraphStageLogic.ConditionalTerminateInput

All Implemented Interfaces:

InHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.ConditionalTerminateInput
extends Object
implements InHandler

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

Constructor Summary

Constructors

Constructor	Description
ConditionalTerminateInput(scala.Function0<Object> predicate)

Method Summary

Modifier and Type	Method	Description
void	onPush()	Called when the input port has a new element available.
void	onUpstreamFinish()	Called when the input port is finished.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.stream.stage.InHandler

onUpstreamFailure

Constructor Details

ConditionalTerminateInput

public ConditionalTerminateInput(scala.Function0<Object> predicate)

Method Details

onPush

public void onPush()

Description copied from interface: InHandler

Called when the input port has a new element available. The actual element can be retrieved via the GraphStageLogic.grab method.

Specified by:

onPush in interface InHandler

onUpstreamFinish

public void onUpstreamFinish()

Description copied from interface: InHandler

Called when the input port is finished. After this callback no other callbacks will be called for this port.

Specified by:

onUpstreamFinish in interface InHandler