Function collect

packages/computer/src/exec-wire.test.ts:22–35

(stream: ReadableStream<T>)

}

async function collect<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;
}

async function roundTrip<E extends "utf8" | undefined>(
  events: WorkspaceExecEvent<E>[],