ktor-io/io.ktor.utils.io/ReaderJob

ReaderJob

class ReaderJob : ChannelJob(source)

Properties

val channel: ByteWriteChannel

val ChannelJob.isCancelled: Boolean

val ChannelJob.isCompleted: Boolean

open override val job: Job

Functions

fun ChannelJob.cancel()

suspend fun flushAndClose()

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

getCancellationException

fun ChannelJob.getCancellationException(): CancellationException

invokeOnCompletion

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

suspend fun ChannelJob.join()