Packages

o

akka.stream.stage.GraphStageLogic

IgnoreTerminateOutput

object IgnoreTerminateOutput extends OutHandler

Output handler that does not terminate the operator upon cancellation.

Source
GraphStage.scala
Linear Supertypes
OutHandler, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. IgnoreTerminateOutput
  2. OutHandler
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def onDownstreamFinish(): Unit

    Called when the output port will no longer accept any new elements.

    Called when the output port will no longer accept any new elements. After this callback no other callbacks will be called for this port.

    Definition Classes
    IgnoreTerminateOutput → OutHandler
  2. def onPull(): Unit

    Called when the output port has received a pull, and therefore ready to emit an element, i.e.

    Called when the output port has received a pull, and therefore ready to emit an element, i.e. GraphStageLogic.push() is now allowed to be called on this port.

    Definition Classes
    IgnoreTerminateOutput → OutHandler
  3. def toString(): String
    Definition Classes
    IgnoreTerminateOutput → AnyRef → Any