Packages

object QueueOfferResult

Contains types that is used as return types for async callbacks to streams

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. All

Type Members

  1. final case class Failure (cause: Throwable) extends QueueOfferResult 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 Enqueued singleton instance

  2. def enqueued: QueueOfferResult

    Java API: The Enqueued singleton instance

  3. object Dropped extends QueueOfferResult with Product with Serializable

    Type is used to indicate that stream is dropped an element

  4. object Enqueued extends QueueOfferResult with Product with Serializable

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

  5. object QueueClosed extends QueueOfferResult with Product with Serializable

    Type is used to indicate that stream is completed before call