o

akka.stream.testkit

GraphStageMessages

object GraphStageMessages

Messages emitted after the corresponding stageUnderTest methods has been invoked.

Source
TestGraphStage.scala
Linear Supertypes
AnyRef, Any
Content Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GraphStageMessages
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. case class Failure(ex: Throwable) extends with with Product with Serializable
  2. case class StageFailure(operation: StageMessage, exception: Throwable) extends Product with Serializable

    Sent to the probe when the operator callback threw an exception

    Sent to the probe when the operator callback threw an exception

    operation

    The operation that failed

  3. sealed trait StageMessage extends AnyRef

Value Members

  1. case object DownstreamFinish extends with with Product with Serializable
  2. case object Pull extends with with Product with Serializable
  3. case object Push extends with with Product with Serializable
  4. case object UpstreamFinish extends with with Product with Serializable