object QueueOfferResult

Contains types that is used as return types for streams Source queues

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

Type Members

  1. final case class Failure(cause: Throwable) extends with Product with Serializable

    Type is used to indicate that stream is failed before or during call to the stream

    Type is used to indicate that stream is failed before or during call to the stream

    cause

    - exception that stream failed with

Value Members

  1. def dropped: QueueOfferResult

    Java API: The Dropped singleton instance

  2. def enqueued: QueueOfferResult

    Java API: The Enqueued singleton instance

  3. case object Dropped extends with Product with Serializable

    Type is used to indicate that stream is dropped an element

  4. case object Enqueued extends with Product with Serializable

    Type is used to indicate that stream is successfully enqueued an element

  5. case object QueueClosed extends with Product with Serializable

    Type is used to indicate that stream is completed before call