ksrpc-core/com.monkopedia.ksrpc.channels/ByteArrayBinaryData

ByteArrayBinaryData

class ByteArrayBinaryData(data: ByteArray, offset: Int = 0, length: Int = data.size - offset) : RpcBinaryData

RpcBinaryData backed by an in-memory ByteArray. Avoids all streaming and coroutine overhead — transferTo delivers the entire buffer in a single callback, and toByteArray returns the array directly.

Constructors

ByteArrayBinaryData

constructor(data: ByteArray, offset: Int = 0, length: Int = data.size - offset)

Properties

size

open override val size: Long

Known byte length, or null for unknown / streaming sources.

Functions

open suspend override fun close()

toByteArray

open suspend override fun toByteArray(): ByteArray

Drain this source into a single ByteArray. Default implementation accumulates transferTo chunks; subclasses that already hold the data in memory should override this to return it directly.

transferTo

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

Pull all bytes from this source into sink. The sink callback may be invoked many times with different offsets / lengths into a buffer the implementation owns; callers must not retain the bytes array beyond the duration of the call.