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
-
-
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()
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()
-
-
-
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. {@link GraphStageLogic.push()} is now allowed to be called on this port.- Specified by:
onPull
in interfaceOutHandler
-
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 interfaceOutHandler
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-