GraphStageLogic.ConditionalTerminateInput

java.lang.Object
- org.apache.pekko.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 operator fails upon receiving a failure.

Constructor Summary

Constructors
Constructor Description

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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 org.apache.pekko.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