akka.stream.stage

Class GraphStageLogic.EagerTerminateInput$

java.lang.Object

akka.stream.stage.GraphStageLogic.EagerTerminateInput$

All Implemented Interfaces:

InHandler

Enclosing class:

GraphStageLogic

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

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
EagerTerminateInput$()

Method Summary

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

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, onUpstreamFinish

Field Detail

MODULE$

public static final GraphStageLogic.EagerTerminateInput$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

EagerTerminateInput$

public EagerTerminateInput$()

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