Function ensureStream

packages/bot-telegram/src/event-renderer.ts:79–91

(messageId: string)

  let pendingInterrupt: CapturedInterrupt | undefined;

  const ensureStream = (messageId: string): ChunkedEditStream | undefined => {
    if (finalised.has(messageId)) return undefined;
    let s = streams.get(messageId);
    if (!s) {
      s = new ChunkedEditStream({
        postPlaceholder: args.postPlaceholder,
        editAt: args.editAt,
        transform: telegramHtml,
      });
      streams.set(messageId, s);
    }
    return s;
  };

  /**
   * BEST-EFFORT cleanup of tool-status placeholders that were posted on START