Function drain

packages/computerd/src/exec/runner.test.ts:34–47

(stream: ReadableStream<ExecEvent>)

}

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

function decode(value: Uint8Array): string {
  return new TextDecoder().decode(value);