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 stage upon cancellation.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
IgnoreTerminateOutput$()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final GraphStageLogic.IgnoreTerminateOutput$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

IgnoreTerminateOutput$

public IgnoreTerminateOutput$()

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

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