ktor-io/io.ktor.utils.io.jvm.nio

Package-level declarations

Types

WriteSuspendSession

class WriteSuspendSession(val channel: ByteWriteChannel)

Functions

asSource

fun ReadableByteChannel.asSource(): RawSource

Converts a ReadableByteChannel into a RawSource.

toByteReadChannel

fun ReadableByteChannel.toByteReadChannel(context: CoroutineContext = Dispatchers.IO): ByteReadChannel

Creates a ByteReadChannel that reads from this channel on demand in the given context. Reads block the executing thread. Use a dispatcher suitable for blocking I/O in context, such as Dispatchers.IO used by default.

writeSuspendSession

suspend fun ByteWriteChannel.~~writeSuspendSession~~(block: suspend WriteSuspendSession.() -> Unit)

writeWhile

inline suspend fun ByteWriteChannel.writeWhile(crossinline block: (ByteBuffer) -> Boolean)