Package akka.stream.stage
Class GraphStageLogic.IgnoreTerminateOutput$
- java.lang.Object
-
- akka.stream.stage.GraphStageLogic.IgnoreTerminateOutput$
-
- All Implemented Interfaces:
OutHandler
- Enclosing class:
- GraphStageLogic
public static class GraphStageLogic.IgnoreTerminateOutput$ extends java.lang.Object implements OutHandler
Output handler that does not terminate the operator upon cancellation.
-
-
Field Summary
Fields Modifier and Type Field Description static GraphStageLogic.IgnoreTerminateOutput$MODULE$Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description IgnoreTerminateOutput$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonDownstreamFinish(java.lang.Throwable cause)Called when the output port will no longer accept any new elements.voidonPull()Called when the output port has received a pull, and therefore ready to emit an element, i.e.java.lang.StringtoString()-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface akka.stream.stage.OutHandler
onDownstreamFinish
-
-
-
-
Field Detail
-
MODULE$
public static final GraphStageLogic.IgnoreTerminateOutput$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
onPull
public void onPull()
Description copied from interface:OutHandlerCalled when the output port has received a pull, and therefore ready to emit an element, i.e.GraphStageLogic.pushis now allowed to be called on this port.- Specified by:
onPullin interfaceOutHandler
-
onDownstreamFinish
public void onDownstreamFinish(java.lang.Throwable cause)
Description copied from interface:OutHandlerCalled 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:
onDownstreamFinishin interfaceOutHandler
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-