Function replayToStream

packages/computerd/src/exec/runner.ts:506–518

(log: EventLog, after: number | "tail")

}

function replayToStream(log: EventLog, after: number | "tail"): ReadableStream<ExecEvent> {
  const iter = log.replay(after)[Symbol.iterator]();
  return new ReadableStream<ExecEvent>({
    pull(controller) {
      const next = iter.next();
      if (next.done === true) {
        controller.close();
        return;
      }
      controller.enqueue(next.value);
    },
  });
}