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 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.java.lang.String
toString()
-
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: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
-
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
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-