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. Protected

Value Members

  1. def onDownstreamFinish(cause: Throwable): 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
    → 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
    → OutHandler
  3. def toString(): String
    Definition Classes
    IgnoreTerminateOutput → AnyRef → Any

Deprecated 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
    OutHandler
    Annotations
    @throws(classOf[Exception]) @deprecatedOverriding() @deprecated
    Deprecated

    (Since version 2.6.0) Call onDownstreamFinish with a cancellation cause.