GraphStageLogic.TotallyIgnorantInput$

java.lang.Object

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

All Implemented Interfaces:: InHandler

Enclosing class:: GraphStageLogic

public static class GraphStageLogic.TotallyIgnorantInput$ extends Object implements InHandler

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

Field Summary

Fields

Modifier and Type

Field

Description

static final GraphStageLogic.TotallyIgnorantInput$

MODULE$

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

Constructors

Constructor

Description

TotallyIgnorantInput$()
Method Summary

Modifier and Type

Method

Description

void

onPush()

Called when the input port has a new element available.

void

onUpstreamFailure(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 Details
- MODULE$
  
  public static final GraphStageLogic.TotallyIgnorantInput$ MODULE$
  
  Static reference to the singleton instance of this Scala object.
Constructor Details
- TotallyIgnorantInput$
  
  public TotallyIgnorantInput$()
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
- onUpstreamFailure
  
  public void onUpstreamFailure(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