ktor-io/io.ktor.utils.io/ByteChannelSequentialJVM

ByteChannelSequentialJVM

class ByteChannelSequentialJVM(initial: <Error class: unknown class>, autoFlush: Boolean)

Constructors

constructor(initial: <Error class: unknown class>, autoFlush: Boolean)

open fun ~~attachJob~~(job: Job)

open suspend fun awaitContent()

Suspend until the channel has bytes to read or gets closed. Throws exception if the channel was closed with an error.

open fun <R> ~~lookAhead~~(visitor: LookAheadSession.() -> R): R

open suspend fun <R> ~~lookAheadSuspend~~(visitor: suspend LookAheadSuspendSession.() -> R): R

open suspend fun read(min: Int, consumer: (ByteBuffer) -> Unit)

open suspend fun readFully(dst: ByteBuffer): Int

open suspend fun write(min: Int, block: (ByteBuffer) -> Unit)

open suspend fun writeFully(src: ByteBuffer)

open suspend fun writeWhile(block: (ByteBuffer) -> Boolean)