Function pull

packages/computer/src/shell.ts:389–411

(controller)

  const stream = new ReadableStream<WorkspaceExecEvent<E>>(
    {
      async pull(controller) {
        try {
          const next = await reader.read();
          if (!next.done) {
            controller.enqueue(next.value);
            return;
          }
          reader.releaseLock();
          const pulled = await runPostPull(sync);
          resolveOutcome(pulled);
          controller.close();
        } catch (error) {
          try {
            reader.releaseLock();
          } catch {}
          resolveOutcome({
            applied: 0,
            skipped: [],
            sync: { status: "pending", applied: 0, skipped: [], error: safeErrorMessage(error) },
          });
          controller.error(error);
        }
      },
      async cancel(reason) {
        try {
          await reader.cancel(reason);