t

akka.stream.stage

OutHandler

trait OutHandler extends AnyRef

Collection of callbacks for an output port of a GraphStage

Source
GraphStage.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
AbstractInOutHandler, AbstractOutHandler, ConditionalTerminateOutput, EagerTerminateOutput, IgnoreTerminateOutput
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. OutHandler
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract 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.

    Annotations
    @throws(classOf[Exception])

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

    Annotations
    @throws(classOf[Exception])

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.

    Annotations
    @throws(classOf[Exception]) @deprecatedOverriding() @deprecated
    Deprecated

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