Package org.apache.pekko.stream.stage

Class GraphStageLogic.IgnoreTerminateOutput$

java.lang.Object

org.apache.pekko.stream.stage.GraphStageLogic.IgnoreTerminateOutput$

All Implemented Interfaces:

OutHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.IgnoreTerminateOutput$
extends Object
implements OutHandler

Output handler that does not terminate the operator upon cancellation.

Field Summary

Fields

Modifier and Type	Field	Description
static final GraphStageLogic.IgnoreTerminateOutput$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
IgnoreTerminateOutput$()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

MODULE$

public static final GraphStageLogic.IgnoreTerminateOutput$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

IgnoreTerminateOutput$

public IgnoreTerminateOutput$()

Method Details

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(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 interface OutHandler

toString

public String toString()

Overrides:

toString in class Object