GraphStageLogic.IgnoreTerminateInput$

java.lang.Object

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

All Implemented Interfaces:: InHandler

Enclosing class:: GraphStageLogic

public static class GraphStageLogic.IgnoreTerminateInput$ extends Object implements InHandler

Input handler that does not terminate the operator upon receiving completion. The operator fails upon receiving a failure.

Field Summary

Fields

Modifier and Type

Field

Description

static final GraphStageLogic.IgnoreTerminateInput$

MODULE$

Static reference to the singleton instance of this Scala object.
Constructor Summary

Constructors

Constructor

Description

IgnoreTerminateInput$()
Method Summary

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.

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

Field Details
- MODULE$
  
  public static final GraphStageLogic.IgnoreTerminateInput$ MODULE$
  
  Static reference to the singleton instance of this Scala object.
Constructor Details
- IgnoreTerminateInput$
  
  public IgnoreTerminateInput$()
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
- 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
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object