zio/zio.internal/RingBuffer

RingBuffer

abstract class RingBuffer[A](val capacity: Int)

See zio.internal.RingBuffer for details on design, tradeoffs, etc.

Companion:
object
class Object
trait Matchable
class Any
class RingBufferArb[A]

Value members

Concrete methods

final override def dequeuedCount(): Long
Definition Classes
MutableConcurrentQueue
final override def enqueuedCount(): Long
Definition Classes
MutableConcurrentQueue
final override def isEmpty(): Boolean
Definition Classes
MutableConcurrentQueue
final override def isFull(): Boolean
Definition Classes
MutableConcurrentQueue
final override def offer(a: A): Boolean
Definition Classes
MutableConcurrentQueue
final override def poll(default: A): A
Definition Classes
MutableConcurrentQueue
final override def size(): Int
Definition Classes
MutableConcurrentQueue

Inherited methods

def offerAll(as: Iterable[A]): Chunk[A]

A non-blocking enqueue of multiple elements.

A non-blocking enqueue of multiple elements.

Inherited from:
MutableConcurrentQueue
def pollUpTo(n: Int): Chunk[A]

A non-blocking dequeue of multiple elements.

A non-blocking dequeue of multiple elements.

Inherited from:
MutableConcurrentQueue

Concrete fields

final override val capacity: Int