Packages

o

akka.stream.testkit

GraphStageMessages

object GraphStageMessages

Messages emitted after the corresponding stageUnderTest methods has been invoked.

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

Type Members

  1. case class Failure(ex: Throwable) extends StageMessage with NoSerializationVerificationNeeded 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. object DownstreamFinish extends StageMessage with NoSerializationVerificationNeeded with Product with Serializable
  2. object Pull extends StageMessage with NoSerializationVerificationNeeded with Product with Serializable
  3. object Push extends StageMessage with NoSerializationVerificationNeeded with Product with Serializable
  4. object UpstreamFinish extends StageMessage with NoSerializationVerificationNeeded with Product with Serializable