Class/Object

monix.execution.misc

AsyncQueue

Related Docs: object AsyncQueue | package misc

Permalink

final class AsyncQueue[T] extends Serializable

And asynchronous queue implementation.

On poll, if there are queued elements, it returns oe immediately, otherwise it returns a Future

Source: AsyncQueue.scala

Linear Supertypes

Serializable, Serializable, AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

AsyncQueue
Serializable
Serializable
AnyRef
Any

Hide All
Show All

Visibility

Public
All

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clear(): Unit

Clears the queue of all offered items or promises.
def clearAndOffer(elem: T): Unit

Clears the whole queue, then offers one item.
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def offer(elem: T): Unit

Enqueues an item in the queue, or feeds it to a waiting consumer if there are such waiting consumers.
Enqueues an item in the queue, or feeds it to a waiting consumer if there are such waiting consumers.

Annotations
@tailrec()
def poll(): Future[T]

If there are elements in the queue, returns one, otherwise returns a Future that waits (asynchronously) until items are offered.
If there are elements in the queue, returns one, otherwise returns a Future that waits (asynchronously) until items are offered.

Annotations
@tailrec()
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped