t

akka.stream.stage

InHandler

trait InHandler extends AnyRef

Collection of callbacks for an input port of a GraphStage

Source
GraphStage.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
AbstractInHandler, AbstractInOutHandler, ConditionalTerminateInput, EagerTerminateInput, IgnoreTerminateInput, TotallyIgnorantInput
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. InHandler
  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 onPush(): Unit

    Called when the input port has a new element available.

    Called when the input port has a new element available. The actual element can be retrieved via the GraphStageLogic.grab method.

    Annotations
    @throws(classOf[Exception])

Concrete Value Members

  1. def onUpstreamFailure(ex: Throwable): Unit

    Called when the input port has failed.

    Called when the input port has failed. After this callback no other callbacks will be called for this port.

    Annotations
    @throws(classOf[Exception])
  2. def onUpstreamFinish(): Unit

    Called when the input port is finished.

    Called when the input port is finished. After this callback no other callbacks will be called for this port.

    Annotations
    @throws(classOf[Exception])