Package 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 operator fails upon receiving a failure.
-
-
Constructor Summary
Constructors Constructor Description ConditionalTerminateOutput(scala.Function0<java.lang.Object> predicate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onDownstreamFinish(java.lang.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
-
Methods inherited from interface akka.stream.stage.OutHandler
onDownstreamFinish
-
-
-
-
Method Detail
-
onDownstreamFinish
public void onDownstreamFinish(java.lang.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 interfaceOutHandler
-
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 interfaceOutHandler
-
-