Function streamOf

packages/computer/src/exec-wire.test.ts:13–20

(items: T[])

import type { WorkspaceExecEvent } from "./shell.js";

function streamOf<T>(items: T[]): ReadableStream<T> {
  return new ReadableStream<T>({
    start(controller) {
      for (const item of items) controller.enqueue(item);
      controller.close();
    },
  });
}

async function collect<T>(stream: ReadableStream<T>): Promise<T[]> {
  const out: T[] = [];