Function makeStream

packages/computer/src/shell.test.ts:92–103

(id: string)

  };

  function makeStream(id: string): ReadableStream<ExecEvent> {
    return new ReadableStream<ExecEvent>({
      start(c) {
        for (const e of events) c.enqueue({ ...e, id });
        if (options.streamError !== undefined) {
          c.error(options.streamError);
          return;
        }
        c.close();
      },
    });
  }

  const sync: SyncRPC = {
    async push() {