BufferingResumableCollector

open class BufferingResumableCollector<T> constructor(capacity: Int) : Resumable

A collector that can buffer a fixed number of items and drain it with much less need to coordinate the resumption per items.

Constructors

fun BufferingResumableCollector(capacity: Int)

Functions

accumulateAndGet

fun accumulateAndGet(p0: Continuation<Any>, p1: BinaryOperator<Continuation<Any>>): Continuation<Any>

await

suspend fun await()

Await the resumption of this Resumable, suspending the current coroutine if necessary.

compareAndExchange

fun compareAndExchange(p0: Continuation<Any>, p1: Continuation<Any>): Continuation<Any>

compareAndExchangeAcquire

fun compareAndExchangeAcquire(p0: Continuation<Any>, p1: Continuation<Any>): Continuation<Any>

compareAndExchangeRelease

fun compareAndExchangeRelease(p0: Continuation<Any>, p1: Continuation<Any>): Continuation<Any>

compareAndSet

fun compareAndSet(p0: Continuation<Any>, p1: Continuation<Any>): Boolean

complete

fun complete()

drain

suspend fun drain(collector: FlowCollector<T>, onCrash: (BufferingResumableCollector<T>) -> Unit? = null)

error

fun error(ex: Throwable)

get

fun get(): Continuation<Any>

getAcquire

fun getAcquire(): Continuation<Any>

getAndAccumulate

fun getAndAccumulate(p0: Continuation<Any>, p1: BinaryOperator<Continuation<Any>>): Continuation<Any>

getAndSet

fun getAndSet(p0: Continuation<Any>): Continuation<Any>

getAndUpdate

fun getAndUpdate(p0: UnaryOperator<Continuation<Any>>): Continuation<Any>

getOpaque

fun getOpaque(): Continuation<Any>

getPlain

fun getPlain(): Continuation<Any>

lazySet

fun lazySet(p0: Continuation<Any>)

suspend fun next(value: T)

resume

fun resume()

Resume this Resumable, resuming any currently suspended await callers.

set

fun set(p0: Continuation<Any>)

setOpaque

fun setOpaque(p0: Continuation<Any>)

setPlain

fun setPlain(p0: Continuation<Any>)

setRelease

fun setRelease(p0: Continuation<Any>)

toString

open override fun toString(): String

updateAndGet

fun updateAndGet(p0: UnaryOperator<Continuation<Any>>): Continuation<Any>

weakCompareAndSet

fun weakCompareAndSet(p0: Continuation<Any>, p1: Continuation<Any>): Boolean

weakCompareAndSetAcquire

fun weakCompareAndSetAcquire(p0: Continuation<Any>, p1: Continuation<Any>): Boolean

weakCompareAndSetPlain

fun weakCompareAndSetPlain(p0: Continuation<Any>, p1: Continuation<Any>): Boolean

weakCompareAndSetRelease

fun weakCompareAndSetRelease(p0: Continuation<Any>, p1: Continuation<Any>): Boolean

weakCompareAndSetVolatile

fun weakCompareAndSetVolatile(p0: Continuation<Any>, p1: Continuation<Any>): Boolean