akka.stream.stage

Class GraphStageLogic.ConditionalTerminateInput

java.lang.Object

akka.stream.stage.GraphStageLogic.ConditionalTerminateInput

All Implemented Interfaces:

InHandler

Enclosing class:

GraphStageLogic

public static class GraphStageLogic.ConditionalTerminateInput
extends java.lang.Object
implements InHandler

Input handler that terminates the state upon receiving completion if the given condition holds at that time. The stage fails upon receiving a failure.

Constructor Summary

Constructors

Constructor and Description
ConditionalTerminateInput(scala.Function0<java.lang.Object> predicate)

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

Constructor Detail

ConditionalTerminateInput

public ConditionalTerminateInput(scala.Function0<java.lang.Object> predicate)

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