base/com.splendo.kaluga.base.utils/BufferedAsListChannel

BufferedAsListChannel

interface BufferedAsListChannel<T : Any> : SendChannel<T> , ReceiveChannel<List<T>>

A Rendezvous Channel that buffers all elements sent to it in a list until the next receive

Parameters

T

the type of element to batch. Must be non-nullable

Properties

isClosedForReceive

abstract val isClosedForReceive: Boolean

isClosedForSend

abstract val isClosedForSend: Boolean

abstract val isEmpty: Boolean

abstract val onReceive: SelectClause1<List<T>>

onReceiveCatching

abstract val onReceiveCatching: SelectClause1<ChannelResult<List<T>>>

onReceiveOrNull

open val ~~onReceiveOrNull~~: SelectClause1<List<T>?>

abstract val onSend: SelectClause2<T, SendChannel<T>>

Functions

abstract fun cancel(cause: CancellationException?)

abstract fun close(cause: Throwable?): Boolean

abstract fun invokeOnClose(handler: (cause: Throwable?) -> Unit)

abstract operator fun iterator(): ChannelIterator<List<T>>

open fun ~~offer~~(element: T): Boolean

open fun ~~poll~~(): List<T>?

abstract suspend fun receive(): List<T>

receiveCatching

abstract suspend fun receiveCatching(): ChannelResult<List<T>>

open suspend fun ~~receiveOrNull~~(): List<T>?

abstract suspend fun send(element: T)

abstract fun tryReceive(): ChannelResult<List<T>>

abstract fun trySend(element: T): ChannelResult<Unit>