akka.stream.stage

Class GraphStageLogic.TotallyIgnorantInput$

java.lang.Object

akka.stream.stage.GraphStageLogic.TotallyIgnorantInput$

All Implemented Interfaces:

InHandler

Enclosing class:

GraphStageLogic

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

Input handler that does not terminate the stage upon receiving completion nor failure.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TotallyIgnorantInput$()

Method Summary

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

Field Detail

MODULE$

public static final GraphStageLogic.TotallyIgnorantInput$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

TotallyIgnorantInput$

public TotallyIgnorantInput$()

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

onUpstreamFailure

public void onUpstreamFailure(java.lang.Throwable ex)

Description copied from interface: InHandler

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

Specified by:

onUpstreamFailure in interface InHandler

Parameters:

ex - (undocumented)