ReaderJob

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override val job: Job

Functions

Link copied to clipboard
Link copied to clipboard
suspend fun flushAndClose()

To avoid the risk of concurrent write operations, we cancel the nested job before performing flushAndClose on the ByteWriteChannel.

Link copied to clipboard
fun ChannelJob.invokeOnCompletion(block: (cause: Throwable?) -> Unit): DisposableHandle
Link copied to clipboard
suspend fun ChannelJob.join()