Packages

o

akka.stream

FlowMonitorState

object FlowMonitorState

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

Type Members

  1. final case class Failed(cause: Throwable) extends StreamState[Nothing] 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. object Finished extends StreamState[Nothing] with Product with Serializable

    Stream completed successfully

  6. object Initialized extends StreamState[Nothing] with Product with Serializable

    Stream was created, but no events have passed through it