Package org.apache.pekko.stream.stage

Class GraphStageLogic.EagerTerminateInput$

java.lang.Object

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

All Implemented Interfaces:

InHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.EagerTerminateInput$
extends Object
implements InHandler

Input handler that terminates the operator upon receiving completion. The operator fails upon receiving a failure.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
EagerTerminateInput$()

Method Summary

Modifier and Type	Method	Description
void	onPush()	Called when the input port has a new element available.
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.InHandler

onUpstreamFailure, onUpstreamFinish

Field Details

MODULE$

public static final GraphStageLogic.EagerTerminateInput$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

EagerTerminateInput$

public EagerTerminateInput$()

Method Details

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

toString

public String toString()

Overrides:

toString in class Object