kuilt-stream/us.tractat.kuilt.stream

Package-level declarations

Types

class FrameTooLargeException(size: Int, max: Int) : Exception

Thrown when a frame exceeds framed's maxFrameSize, in either direction: an oversize send throws before writing, and a received length prefix over the limit throws before any allocation is performed (the flow terminates immediately).

Properties

DEFAULT_MAX_FRAME_SIZE

const val DEFAULT_MAX_FRAME_SIZE: Int

Default maximum frame size (16 MiB).

Functions

framed

fun framed(source: Source, sink: Sink, maxFrameSize: Int = DEFAULT_MAX_FRAME_SIZE): Connection

Adapt a kotlinx-io Source/Sink byte-stream into a message Connection using a 4-byte big-endian length prefix per frame.