Apache Pekko
2.0.0-M3
API
Generated with
Apache Pekko/org.apache.pekko/org.apache.pekko.util/BoundedBlockingQueue

BoundedBlockingQueue

org.apache.pekko.util.BoundedBlockingQueue
class BoundedBlockingQueue[E <: AnyRef](val maxCapacity: Int, backing: Queue[E]) extends AbstractQueue[E], BlockingQueue[E]

BoundedBlockingQueue wraps any Queue and turns the result into a BlockingQueue with a limited capacity.

Value parameters

backing
  • the backing Queue
maxCapacity
  • the maximum capacity of this Queue, needs to be > 0

Attributes

Source
BoundedBlockingQueue.scala
Graph
Supertypes
trait BlockingQueue[E]
class AbstractQueue[E]
trait Queue[E]
class AbstractCollection[E]
trait Collection[E]
trait Iterable[E]
class Object
trait Matchable
class Any
Show all
Known subtypes
class MessageQueue
class MessageQueue

Members list

Value members

Concrete methods

override def clear(): Unit

Attributes

Definition Classes
AbstractQueue -> AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala
override def contains(e: AnyRef): Boolean

Attributes

Definition Classes
BlockingQueue -> AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala
override def containsAll(c: Collection[_]): Boolean

Attributes

Definition Classes
AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala
def drainTo(c: Collection[_ >: E]): Int

Attributes

Source
BoundedBlockingQueue.scala
def drainTo(c: Collection[_ >: E], maxElements: Int): Int

Attributes

Source
BoundedBlockingQueue.scala
override def isEmpty(): Boolean

Attributes

Definition Classes
AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala
def iterator(): Iterator[E]

Attributes

Source
BoundedBlockingQueue.scala
def offer(e: E): Boolean

Attributes

Source
BoundedBlockingQueue.scala
def offer(e: E, timeout: Long, unit: TimeUnit): Boolean

Attributes

Source
BoundedBlockingQueue.scala
def peek(): E

Attributes

Source
BoundedBlockingQueue.scala
def poll(timeout: Long, unit: TimeUnit): E

Attributes

Source
BoundedBlockingQueue.scala
def poll(): E

Attributes

Source
BoundedBlockingQueue.scala
def put(e: E): Unit

Attributes

Source
BoundedBlockingQueue.scala
override def remove(e: AnyRef): Boolean

Attributes

Definition Classes
BlockingQueue -> AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala
override def removeAll(c: Collection[_]): Boolean

Attributes

Definition Classes
AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala
override def retainAll(c: Collection[_]): Boolean

Attributes

Definition Classes
AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala
def size(): Int

Attributes

Source
BoundedBlockingQueue.scala
def take(): E

Attributes

Source
BoundedBlockingQueue.scala
override def toArray(): Array[AnyRef]

Attributes

Definition Classes
AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala
override def toArray[X](a: Array[X & AnyRef]): Array[Object & X]

Attributes

Definition Classes
AbstractCollection -> Collection
Source
BoundedBlockingQueue.scala

Inherited methods

def add(x$0: E): Boolean

Attributes

Inherited from:
AbstractQueue
def addAll(x$0: Collection[_ <: E]): Boolean

Attributes

Inherited from:
AbstractQueue
def element(): E

Attributes

Inherited from:
AbstractQueue
def forEach(x$0: Consumer[_ >: E <: <FromJavaObject>]): Unit

Attributes

Inherited from:
Iterable
def parallelStream(): Stream[E]

Attributes

Inherited from:
Collection
def remove(): E

Attributes

Inherited from:
AbstractQueue
def removeIf(x$0: Predicate[_ >: E <: <FromJavaObject>]): Boolean

Attributes

Inherited from:
Collection
def spliterator(): Spliterator[E]

Attributes

Inherited from:
Collection
def stream(): Stream[E]

Attributes

Inherited from:
Collection
def toArray[T <: <FromJavaObject>](x$0: IntFunction[Array[Object & T]]): Array[Object & T]

Attributes

Inherited from:
Collection
def toString(): String

Returns a string representation of the object.

Returns a string representation of the object.

The default representation is platform dependent.

Attributes

Returns

a string representation of the object.

Inherited from:
AbstractCollection

Concrete fields

val maxCapacity: Int

Attributes

Source
BoundedBlockingQueue.scala
Generated with