QueueWriteLayer

interface QueueWriteLayer<T>

Functions

Link copied to clipboard
open suspend fun clear()
Link copied to clipboard
abstract suspend fun peek(n: Int): List<T>
Link copied to clipboard
abstract suspend fun pop(n: Int)
Link copied to clipboard
abstract suspend fun push(t: List<T>)
Link copied to clipboard
abstract suspend fun size(): Int

Properties

Link copied to clipboard
abstract val concurrentPushPop: Boolean

Specify whether this write layer is capable of handling pushing and popping concurrently. The queue handler will parallelize the incoming push/pop requests if this can support it. Otherwise, they will be serialized.

Inheritors

Link copied to clipboard
Link copied to clipboard