Function flushPending

packages/computer/src/runtime/runtime.ts:357–390

(
    controller: TransformStreamDefaultController<WorkspaceRuntimeEvent<E>>,
    beforeSeq?: number,
  )

    controller.enqueue(event);
  };
  const flushPending = (
    controller: TransformStreamDefaultController<WorkspaceRuntimeEvent<E>>,
    beforeSeq?: number,
  ) => {
    const pending: WorkspaceRuntimeEvent<E>[] = [];
    const stdout = stdoutDecoder.decode();
    const stderr = stderrDecoder.decode();
    if (stdout && stdoutMeta) {
      pending.push({
        ...stdoutMeta,
        name: "stdout",
        value: stdout,
      } as WorkspaceRuntimeEvent<E>);
    }
    if (stderr && stderrMeta) {
      pending.push({
        ...stderrMeta,
        name: "stderr",
        value: stderr,
      } as WorkspaceRuntimeEvent<E>);
    }
    pending.sort((a, b) => a.seq - b.seq);
    const span = beforeSeq !== undefined && beforeSeq > lastSeq ? beforeSeq - lastSeq : 1;
    let index = 0;
    for (const event of pending) {
      index += 1;
      enqueue(controller, {
        ...event,
        seq: lastSeq + (span * index) / (pending.length + 1),
      } as WorkspaceRuntimeEvent<E>);
    }
    stdoutMeta = undefined;
    stderrMeta = undefined;
  };
  return source.pipeThrough(
    new TransformStream<WorkspaceRuntimeEvent, WorkspaceRuntimeEvent<E>>({
      transform(event, controller) {