Commons/cz.acrobits.commons/SendProducerScope

SendProducerScope

interface SendProducerScope<T> : ProducerScope<T>

Properties

channel

abstract val channel: SendChannel<T>

coroutineContext

abstract val coroutineContext: CoroutineContext

isClosedForSend

@DelicateCoroutinesApi

abstract val isClosedForSend: Boolean

onSend

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

Functions

awaitSend

suspend fun <T> ProducerScope<T>.awaitSend(block: suspend SendProducerScope<T>.() -> Unit)

buildCompletable

fun CoroutineScope.buildCompletable(): Completable

fun CoroutineScope.buildCompletable(action: CompletableBuilder.() -> Unit): Completable

Builds a completable that can be completed, executing all deferred actions in reverse order of their registration.

childJobScope

fun CoroutineScope.childJobScope(context: CoroutineContext = EmptyCoroutineContext): CoroutineScope

Creates a new CoroutineScope with a Job that is a child of the current scope's job. This allows for launching coroutines that are cancelled when the parent scope is cancelled.

childSupervisorJobScope

fun CoroutineScope.childSupervisorJobScope(context: CoroutineContext = EmptyCoroutineContext): CoroutineScope

Creates a new CoroutineScope with a SupervisorJob that is a child of the current scope's job. This allows for launching coroutines that can fail independently of the parent scope.

abstract fun close(cause: Throwable?): Boolean

invokeOnClose

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

invokeOnCompletion

fun CoroutineScope.invokeOnCompletion(block: (cause: Throwable?) -> Unit): DisposableHandle

offer

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

onClose

abstract fun onClose(block: () -> Unit)

send

abstract suspend fun send(element: T)

sendAsync

abstract fun sendAsync(value: T): Deferred<T>

sendAsyncLatest

abstract fun sendAsyncLatest(value: T)

trySend

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