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

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(): 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] )