t

akka.stream

BoundedSourceQueue

trait BoundedSourceQueue[T] extends AnyRef

A queue of the given size that gives immediate feedback whether an element could be enqueued or not.

Not for user extension

Annotations
@DoNotInherit()
Source
BoundedSourceQueue.scala
Linear Supertypes
AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BoundedSourceQueue
  2. AnyRef
  3. 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

Abstract Value Members

  1. abstract def complete(): Unit

    Completes the stream normally.

  2. abstract def fail(ex: Throwable): Unit

    Completes the stream with a failure.

  3. abstract def offer(elem: T): QueueOfferResult

    Returns a akka.stream.QueueOfferResult that notifies the caller if the element could be enqueued or not, or the completion status of the queue.

    Returns a akka.stream.QueueOfferResult that notifies the caller if the element could be enqueued or not, or the completion status of the queue.

    A result of QueueOfferResult.Enqueued does not guarantee that an element also has been or will be processed by the downstream.

  4. abstract def size(): Int

    Returns the approximate number of elements in this queue.