Attributes
- Companion
- class
- Source
- Queue.scala
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
Queue.type
Members list
Type members
Classlikes
Attributes
- Source
- Queue.scala
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
unsafe.type
Inherited types
Attributes
- Inherited from:
- QueuePlatformSpecific (hidden)
- Source
- QueuePlatformSpecific.scala
Value members
Concrete methods
Makes a new bounded queue. When the capacity of the queue is reached, any additional calls to offer will be suspended until there is more room in the queue.
Makes a new bounded queue. When the capacity of the queue is reached, any additional calls to offer will be suspended until there is more room in the queue.
Type parameters
- A
-
type of the
Queue
Value parameters
- requestedCapacity
-
capacity of the
Queue
Attributes
- Returns
-
UIO[Queue[A]] - Note
-
when possible use only power of 2 capacities; this will provide better performance by utilising an optimised version of the underlying zio.internal.RingBuffer.
- Source
- Queue.scala
Makes a new bounded queue with the dropping strategy. When the capacity of the queue is reached, new elements will be dropped.
Makes a new bounded queue with the dropping strategy. When the capacity of the queue is reached, new elements will be dropped.
Type parameters
- A
-
type of the
Queue
Value parameters
- requestedCapacity
-
capacity of the
Queue
Attributes
- Returns
-
UIO[Queue[A]] - Note
-
when possible use only power of 2 capacities; this will provide better performance by utilising an optimised version of the underlying zio.internal.RingBuffer.
- Source
- Queue.scala
Makes a new bounded queue with sliding strategy. When the capacity of the queue is reached, new elements will be added and the old elements will be dropped.
Makes a new bounded queue with sliding strategy. When the capacity of the queue is reached, new elements will be added and the old elements will be dropped.
Type parameters
- A
-
type of the
Queue
Value parameters
- requestedCapacity
-
capacity of the
Queue
Attributes
- Returns
-
UIO[Queue[A]] - Note
-
when possible use only power of 2 capacities; this will provide better performance by utilising an optimised version of the underlying zio.internal.RingBuffer.
- Source
- Queue.scala
Makes a new unbounded queue.
Makes a new unbounded queue.
Type parameters
- A
-
type of the
Queue
Attributes
- Returns
-
UIO[Queue[A]] - Source
- Queue.scala