Package org.apache.pekko.stream.stage

Class GraphStageLogic.ConditionalTerminateOutput

java.lang.Object

org.apache.pekko.stream.stage.GraphStageLogic.ConditionalTerminateOutput

All Implemented Interfaces:

OutHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.ConditionalTerminateOutput
extends Object
implements OutHandler

Output 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
ConditionalTerminateOutput(scala.Function0<Object> predicate)

Method Summary

Modifier and Type	Method	Description
void	onDownstreamFinish(Throwable cause)	Called when the output port will no longer accept any new elements.
void	onPull()	Called when the output port has received a pull, and therefore ready to emit an element, i.e.

Methods inherited from class java.lang.Object

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

Constructor Details

ConditionalTerminateOutput

public ConditionalTerminateOutput(scala.Function0<Object> predicate)

Method Details

onDownstreamFinish

public void onDownstreamFinish(Throwable cause)

Description copied from interface: OutHandler

Called when the output port will no longer accept any new elements. After this callback no other callbacks will be called for this port.

Specified by:

onDownstreamFinish in interface OutHandler

onPull

public void onPull()

Description copied from interface: OutHandler

Called when the output port has received a pull, and therefore ready to emit an element, i.e. GraphStageLogic.push is now allowed to be called on this port.

Specified by:

onPull in interface OutHandler