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

PriorityQueueStabilizer

org.apache.pekko.util.PriorityQueueStabilizer
See thePriorityQueueStabilizer companion object
trait PriorityQueueStabilizer[E <: AnyRef] extends AbstractQueue[E]

PriorityQueueStabilizer wraps a priority queue so that it respects FIFO for elements of equal priority.

Attributes

Companion
object
Source
StablePriorityQueue.scala
Graph
Supertypes
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

Members list

Value members

Concrete methods

override def iterator(): Iterator[E]

Attributes

Definition Classes
AbstractCollection -> Collection -> Iterable
Source
StablePriorityQueue.scala
override def offer(e: E): Boolean

Attributes

Definition Classes
Queue
Source
StablePriorityQueue.scala
override def peek(): E

Attributes

Definition Classes
Queue
Source
StablePriorityQueue.scala
override def poll(): E

Attributes

Definition Classes
Queue
Source
StablePriorityQueue.scala
override def size(): Int

Attributes

Definition Classes
AbstractCollection -> Collection
Source
StablePriorityQueue.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 clear(): Unit

Attributes

Inherited from:
AbstractQueue
def contains(x$0: <FromJavaObject>): Boolean

Attributes

Inherited from:
AbstractCollection
def containsAll(x$0: Collection[_ <: <FromJavaObject>]): Boolean

Attributes

Inherited from:
AbstractCollection
def element(): E

Attributes

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

Attributes

Inherited from:
Iterable
def isEmpty(): Boolean

Attributes

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

Attributes

Inherited from:
Collection
def remove(): E

Attributes

Inherited from:
AbstractQueue
def remove(x$0: <FromJavaObject>): Boolean

Attributes

Inherited from:
AbstractCollection
def removeAll(x$0: Collection[_ <: <FromJavaObject>]): Boolean

Attributes

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

Attributes

Inherited from:
Collection
def retainAll(x$0: Collection[_ <: <FromJavaObject>]): Boolean

Attributes

Inherited from:
AbstractCollection
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 toArray[T <: <FromJavaObject>](x$0: Array[Object & T]): Array[Object & T]

Attributes

Inherited from:
AbstractCollection
def toArray(): Array[<FromJavaObject>]

Attributes

Inherited from:
AbstractCollection
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

Abstract fields

val backingQueue: AbstractQueue[WrappedElement[E]]

Attributes

Source
StablePriorityQueue.scala

Concrete fields

val seqNum: AtomicLong

Attributes

Source
StablePriorityQueue.scala
Generated with