akka.stream.stage

Class GraphStageLogic.EagerTerminateOutput$

java.lang.Object

akka.stream.stage.GraphStageLogic.EagerTerminateOutput$

All Implemented Interfaces:

OutHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.EagerTerminateOutput$
extends java.lang.Object
implements OutHandler

Output handler that terminates the stage upon cancellation.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
EagerTerminateOutput$()

Method Summary

Modifier and Type	Method and Description
void	onPull() Called when the output port has received a pull, and therefore ready to emit an element, i.e.

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.stage.OutHandler

onDownstreamFinish

Field Detail

MODULE$

public static final GraphStageLogic.EagerTerminateOutput$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

EagerTerminateOutput$

public EagerTerminateOutput$()

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