Class ByteReassembler

Bounded out-of-order and interleaved byte-message reassembly.

Feed packets as WebSocket/WebRTC callbacks deliver them. Packets belonging to several transient message ids may interleave and arrive out of sequence; a complete owned byte array is returned only when every piece is present. Limits prevent an untrusted peer from retaining unbounded partial data.

Index

Properties

Accessors

pendingByteCount pendingMessageCount

Methods

clear feed create

Properties

`Readonly`options

options: Readonly<NormalizedByteChunkingOptions>

Accessors

pendingByteCount

get pendingByteCount(): number
Aggregate payload bytes retained for incomplete messages.

Returns number
- Defined in src/byte_chunking.ts:300

pendingMessageCount

get pendingMessageCount(): number
Number of transient ids still waiting for packets.

Returns number
- Defined in src/byte_chunking.ts:295

Methods

clear

clear(): Status
Discard partial messages when a channel resets or aborts.

Returns Status
- Defined in src/byte_chunking.ts:305

feed

feed(source: ByteSource): StatusOr<Uint8Array<ArrayBufferLike> | null>
Admit one packet and return a full message when this completes one.
Parameters
- source: ByteSource
Returns StatusOr<Uint8Array<ArrayBufferLike> | null>
- Defined in src/byte_chunking.ts:312

`Static`create

create(options?: ByteChunkingOptions): StatusOr<ByteReassembler>
Validate limits and create an empty reassembly table.
Parameters
- options: ByteChunkingOptions = {}
Returns StatusOr<ByteReassembler>
- Defined in src/byte_chunking.ts:285