Function streamFor

packages/rpc/tests/shell-and-composite.test.ts:54–61

(rec: ExecRecord)

  let counter = 0;

  function streamFor(rec: ExecRecord): ReadableStream<ExecEvent> {
    return new ReadableStream<ExecEvent>({
      start(controller) {
        for (const ev of rec.events) controller.enqueue(ev);
        controller.close();
      },
    });
  }

  return {
    records,