akka.stream.stage

Class GraphStageLogic.IgnoreTerminateInput$

java.lang.Object

akka.stream.stage.GraphStageLogic.IgnoreTerminateInput$

All Implemented Interfaces:

InHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.IgnoreTerminateInput$
extends java.lang.Object
implements InHandler

Input handler that does not terminate the stage upon receiving completion. The stage fails upon receiving a failure.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
IgnoreTerminateInput$()

Method Summary

Modifier and Type	Method and Description
void	onPush() Called when the input port has a new element available.
void	onUpstreamFinish() Called when the input port is finished.

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.InHandler

onUpstreamFailure

Field Detail

MODULE$

public static final GraphStageLogic.IgnoreTerminateInput$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

IgnoreTerminateInput$

public IgnoreTerminateInput$()

Method Detail

onPush

public void onPush()

Description copied from interface: InHandler

Called when the input port has a new element available. The actual element can be retrieved via the GraphStageLogic.grab() method.

Specified by:

onPush in interface InHandler

onUpstreamFinish

public void onUpstreamFinish()

Description copied from interface: InHandler

Called when the input port is finished. After this callback no other callbacks will be called for this port.

Specified by:

onUpstreamFinish in interface InHandler