Function transform

packages/computer/src/runtime/runtime.ts:393–407

(event, controller)

  return source.pipeThrough(
    new TransformStream<WorkspaceRuntimeEvent, WorkspaceRuntimeEvent<E>>({
      transform(event, controller) {
        if (event.name === "stdout" || event.name === "stderr") {
          if (event.name === "stdout") stdoutMeta = { id: event.id, seq: event.seq };
          else stderrMeta = { id: event.id, seq: event.seq };
          enqueue(controller, {
            ...event,
            value: (event.name === "stdout" ? stdoutDecoder : stderrDecoder).decode(event.value, {
              stream: true,
            }),
          } as WorkspaceRuntimeEvent<E>);
        } else {
          if (event.name === "exit") flushPending(controller, event.seq);
          enqueue(controller, event as WorkspaceRuntimeEvent<E>);
        }
      },
      flush: flushPending,
    }),
  );