refactor: add `MessageIO.writeMessage`/`readMessage` and use them for the `PRELOGIN` exchange#1756

Open

arthurschreiber wants to merge 14 commits into

arthur/message-io-statics

Commits on Jul 19, 2026

fix: prevent `readMessage` hang when the stream closes during chunk processing

arthurschreiber
and
claude
committed
perf: build outgoing packets in a single allocation

arthurschreiber
and
claude
committed
fix: fail `writeMessage` cleanly when the stream closes mid-write

arthurschreiber
and
claude
committed
fix: close the payload iterator when `writeMessage` exits early

arthurschreiber
and
claude
committed
test: cover the `resetConnection` option of `writeMessage`

arthurschreiber
and
claude
committed
test: also check for dangling `close` listeners

arthurschreiber
and
claude
committed
docs: document `readMessage`'s consume-to-completion contract

arthurschreiber
and
claude
committed
refactor: decide cancellation from the `canceled` flag instead of a sentinel value

arthurschreiber
and
claude
committed
refactor: tighten the types of the race contender arrays

arthurschreiber
and
claude
committed
fix: skip drain waits when the cancel signal was already aborted at call time

arthurschreiber
and
claude
committed