object FlowMonitorState
- Alphabetic
- By Inheritance
- FlowMonitorState
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class Failed(cause: Throwable) extends StreamState[Nothing] with Product with Serializable
Stream failed
Stream failed
- cause
The cause of the failure
- 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
- sealed trait StreamState[+U] extends AnyRef
Value Members
- def failed[U](cause: Throwable): StreamState[U]
Java API
- def finished[U](): StreamState[U]
Java API
- def initialized[U](): StreamState[U]
Java API
- def received[U](msg: U): StreamState[U]
Java API
- case object Finished extends StreamState[Nothing] with Product with Serializable
Stream completed successfully
- case object Initialized extends StreamState[Nothing] with Product with Serializable
Stream was created, but no events have passed through it