whylogs-container/ai.whylabs.services.whylogs.persistent.queue/PersistentQueue

PersistentQueue

class PersistentQueue<T>(options: QueueOptions<T>)
Content copied to clipboard

Constructors

Link copied to clipboard
fun <T> PersistentQueue(options: QueueOptions<T>)
Content copied to clipboard

Functions

Link copied to clipboard
suspend fun pop(count: PopSize, block: suspend (List<T>) -> Unit)
Content copied to clipboard
Link copied to clipboard
suspend fun popUntilEmpty(incrementSize: PopSize, block: suspend (List<T>) -> Unit)
Content copied to clipboard
Link copied to clipboard
suspend fun push(items: List<T>)
Content copied to clipboard