ksrpc-binary-ktor/com.monkopedia.ksrpc.binary.ktor/ByteReadChannelBinaryData

ByteReadChannelBinaryData

class ByteReadChannelBinaryData(channel: ByteReadChannel, val size: Long? = null) : RpcBinaryData

Bridge from ktor's ByteReadChannel onto the transport-agnostic RpcBinaryData interface. Lives here (rather than in ksrpc-core) so that ksrpc-core does not publicly depend on ktor — consumers opt in to the ktor-io adapter by adding ksrpc-binary-ktor to their classpath.

Constructors

constructor(channel: ByteReadChannel, size: Long? = null)

Properties

size

open override val size: Long?

Functions

asByteReadChannel

fun RpcBinaryData.asByteReadChannel(scope: CoroutineScope = CoroutineScope(Dispatchers.Default)): ByteReadChannel

Expose an RpcBinaryData as a ByteReadChannel. Unwraps directly when the underlying data is already a ByteReadChannelBinaryData; otherwise spins up a pump coroutine that drains RpcBinaryData.transferTo into a new ktor ByteChannel.

open suspend override fun close()

transferTo

open suspend override fun transferTo(sink: suspend (bytes: ByteArray, offset: Int, length: Int) -> Unit)