akka.stream.stage

Class GraphStageLogic.ConditionalTerminateOutput

java.lang.Object

akka.stream.stage.GraphStageLogic.ConditionalTerminateOutput

All Implemented Interfaces:

OutHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.ConditionalTerminateOutput
extends java.lang.Object
implements OutHandler

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

Constructor Summary

Constructors

Constructor and Description
ConditionalTerminateOutput(scala.Function0<java.lang.Object> predicate)

Method Summary

Modifier and Type	Method and Description
void	onDownstreamFinish() 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 Detail

ConditionalTerminateOutput

public ConditionalTerminateOutput(scala.Function0<java.lang.Object> predicate)

Method Detail

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

onDownstreamFinish

public void onDownstreamFinish()

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