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

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

cause

- exception that stream failed with

Source
QueueOfferResult.scala
Linear Supertypes
Serializable, Product, Equals, QueueCompletionResult, QueueOfferResult, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Failure
  2. Serializable
  3. Product
  4. Equals
  5. QueueCompletionResult
  6. QueueOfferResult
  7. AnyRef
  8. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Failure(cause: Throwable)

    cause

    - exception that stream failed with

Value Members

  1. val cause: Throwable
  2. def isEnqueued: Boolean

    Return ture if the element was already enqueued, otherwise false.

    Return ture if the element was already enqueued, otherwise false.

    Definition Classes
    → QueueOfferResult
  3. def productElementNames: Iterator[String]
    Definition Classes
    Product