Function markInterrupted

packages/bot-slack/src/event-renderer.ts:542–573

()

      await finalizeTurnStream();
    },
    async markInterrupted() {
      // Idempotent. Mark BEFORE any await so subsequent subscriber
      // callbacks (including the RUN_ERROR that AG-UI fires when we
      // abort) see the flag and bail.
      if (aborted) return;
      aborted = true;
      // Clear the native status; the interrupted marker (or the next turn) is
      // the user-visible signal now.
      if (statusMode) await clearStatus();
      // Native turn stream: append the interrupted marker to the partial reply
      // and finalize it.
      if (nativeMode) {
        if (turnStream && turnText.length > 0 && !turnFinalised) {
          turnStream.append(turnText + INTERRUPTED_SUFFIX);
        }
        await finalizeTurnStream();
      }
      // Legacy per-message streams: append the marker and drain. Streams with
      // no content yet are silently dropped (the bot never posted anything).
      const tasks: Promise<void>[] = [];
      for (const [id, stream] of Array.from(streams.entries())) {
        const buf = buffers.get(id) ?? "";
        if (buf.length > 0) {
          stream.append(buf + INTERRUPTED_SUFFIX);
          tasks.push(stream.finish());
        }
        streams.delete(id);
        finalised.add(id);
      }
      buffers.clear();
      await Promise.all(tasks);
    },
  };
}