o

akka.stream

FlowMonitorState

object FlowMonitorState

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

Type Members

  1. final case class Failed(cause: Throwable) extends [] with Product with Serializable

    Stream failed

    Stream failed

    cause

    The cause of the failure

  2. final case class Received[+U](msg: U) extends StreamState[U] with Product with Serializable

    Stream processed a message

    Stream processed a message

    msg

    The processed message

  3. sealed trait StreamState[+U] extends AnyRef

Value Members

  1. def failed[U](cause: Throwable): StreamState[U]

    Java API

  2. def finished[U](): StreamState[U]

    Java API

  3. def initialized[U](): StreamState[U]

    Java API

  4. def received[U](msg: U): StreamState[U]

    Java API

  5. case object Finished extends [] with Product with Serializable

    Stream completed successfully

  6. case object Initialized extends [] with Product with Serializable

    Stream was created, but no events have passed through it