Function transform

packages/computer/src/shell.ts:345–366

(event, controller)

  return source.pipeThrough(
    new TransformStream<ExecEvent, WorkspaceExecEvent<E>>({
      transform(event, controller) {
        if (event.name === "stdout") {
          stdoutMeta = { id: event.id, seq: event.seq };
          enqueue(controller, {
            id: event.id,
            seq: event.seq,
            name: "stdout",
            value: stdoutDec.decode(event.value, { stream: true }) as Chunk<E>,
          });
        } else if (event.name === "stderr") {
          stderrMeta = { id: event.id, seq: event.seq };
          enqueue(controller, {
            id: event.id,
            seq: event.seq,
            name: "stderr",
            value: stderrDec.decode(event.value, { stream: true }) as Chunk<E>,
          });
        } else {
          flushPending(controller, event.seq);
          enqueue(controller, event as WorkspaceExecEvent<E>);
        }
      },
      flush: flushPending,
    }),
  );