Function drainStream

packages/rpc/src/sync-driver.test.ts:39–52

(stream: ReadableStream<T>)

}

async function drainStream<T>(stream: ReadableStream<T>): Promise<T[]> {
  const out: T[] = [];
  const reader = stream.getReader();
  try {
    while (true) {
      const { value, done } = await reader.read();
      if (done) break;
      out.push(value);
    }
  } finally {
    reader.releaseLock();
  }
  return out;
}

// Wrap a SyncRPC so the fetchChanges result carries a tracked
// [Symbol.dispose]. pullOnce owns that envelope and must dispose it on