Package org.apache.pekko.stream.stage

Class GraphStageLogic.EagerTerminateOutput$

java.lang.Object

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

All Implemented Interfaces:

OutHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.EagerTerminateOutput$
extends Object
implements OutHandler

Output handler that terminates the operator upon cancellation.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
EagerTerminateOutput$()

Method Summary

Modifier and Type	Method	Description
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

Methods inherited from interface org.apache.pekko.stream.stage.OutHandler

onDownstreamFinish

Field Details

MODULE$

public static final GraphStageLogic.EagerTerminateOutput$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

EagerTerminateOutput$

public EagerTerminateOutput$()

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

toString

public String toString()

Overrides:

toString in class Object