TEnqueue

zio.stm.TEnqueue
sealed trait TEnqueue[-A] extends Serializable

A transactional queue that can only be enqueued.

Attributes

Source
TEnqueue.scala
Graph
Supertypes
trait Serializable
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

def capacity: Int

The maximum capacity of the queue.

The maximum capacity of the queue.

Attributes

Source
TEnqueue.scala

Checks whether the queue is shut down.

Checks whether the queue is shut down.

Attributes

Source
TEnqueue.scala
def offer(a: A): ZSTM[Any, Nothing, Boolean]

Offers a value to the queue, returning whether the value was offered to the queue.

Offers a value to the queue, returning whether the value was offered to the queue.

Attributes

Source
TEnqueue.scala
def offerAll(as: Iterable[A]): ZSTM[Any, Nothing, Boolean]

Offers all of the specified values to the queue, returning whether they were offered to the queue.

Offers all of the specified values to the queue, returning whether they were offered to the queue.

Attributes

Source
TEnqueue.scala

Shuts down the queue.

Shuts down the queue.

Attributes

Source
TEnqueue.scala
def size: USTM[Int]

The current number of values in the queue.

The current number of values in the queue.

Attributes

Source
TEnqueue.scala

Concrete methods

Waits for the hub to be shut down.

Waits for the hub to be shut down.

Attributes

Source
TEnqueue.scala

Checks if the queue is empty.

Checks if the queue is empty.

Attributes

Source
TEnqueue.scala

Checks if the queue is at capacity.

Checks if the queue is at capacity.

Attributes

Source
TEnqueue.scala