Function readExact

crates/opencode-plugin/host/plugin-host.ts:87–114

* Read exactly `n` bytes from stdin.

(n: number)

 * Read exactly `n` bytes from stdin.
 */
async function readExact(n: number): Promise<Uint8Array> {
  const chunks: Uint8Array[] = [];
  let remaining = n;

  const reader = process.stdin as unknown as {
    read(size: number): Uint8Array | null;
    once(event: string, cb: () => void): void;
  };

  while (remaining > 0) {
    const chunk: Uint8Array | null = reader.read(remaining);
    if (chunk !== null) {
      chunks.push(chunk);
      remaining -= chunk.length;
    } else {
      await new Promise<void>((resolve) => reader.once("readable", resolve));
    }
  }

  if (chunks.length === 1) return chunks[0];
  const result = new Uint8Array(n);
  let offset = 0;
  for (const c of chunks) {
    result.set(c, offset);
    offset += c.length;
  }
  return result;
}

/**
 * Read one Content-Length framed JSON-RPC message from stdin.