ResumableCollector

open class ResumableCollector<T> : Resumable

A collector that hosts a signal (value/error/completion) and allows waiting for the signal and a consumer to be ready to receive them.

Constructors

ResumableCollector

fun ResumableCollector()

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

suspend fun complete()

drain

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

error

suspend fun error(error: 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)

readyConsumer

fun readyConsumer()

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

Properties

error

var error: Throwable? = null

value

var value: T