* Build a `i32(LEAD), X, i32(TRAIL)` row, run it, and return a fresh reader over * the bytes. Each test reads the leading sentinel, X, and the traili

Decode a single-column, single-row `... AS v` SELECT down to its value.

Build `i32(LEAD), X, Y, i32(TRAIL)` and return a reader over the bytes.

Argument accessor that fails loudly instead of returning `undefined`.

* Drive `writeRows` to completion and concatenate every yielded buffer — the * canonical driver loop. `bufferSize` sizes each (fixed) sink, so a smal

* Compile a `SELECT ... FORMAT RowBinaryWithNamesAndTypes` response and decode * every row. Asserts the stream is consumed EXACTLY — the strongest si

Fold `type` to a reader and decode one `expr` value (`FORMAT RowBinary`).

Reads an integer out of a `Literal` argument node (e.g. the N in FixedString(N)).

* `streamRowBatches` is the async front door over `readRows`: an async iterable * of byte chunks in, an async generator of row batches out. A real HT

* Int16 is 2 bytes, little-endian, two's-complement. Each case selects the * value with `FORMAT RowBinary` and decodes the bytes the server produces.

* RowBinary prefixes every String with its length as a LEB128 unsigned varint. * So a real, server-encoded varint of value N is just the leading byte

* The written bytes — `buf.subarray(0, pos)`. A zero-copy VIEW into the sink's * buffer, so use `Buffer.from(sink.bytes())` if you need an independ

Yield `buf` in chunks of the given repeating sizes (deliberately mid-row).

Drain the columnar stream into flat per-column arrays.