​

Streaming + chunking

• Strumieniowanie blokowe (kanały): emituje ukończone bloki podczas pisania przez asystenta. Są to zwykłe wiadomości kanału (nie delty tokenów).
• Strumieniowanie podglądu (Telegram/Discord/Slack): aktualizuje tymczasową wiadomość podglądu podczas generowania.

​

Strumieniowanie blokowe (wiadomości kanału)

Dane wyjściowe modelu
  └─ text_delta/events
       ├─ (blockStreamingBreak=text_end)
       │    └─ chunker emituje bloki w miarę wzrostu bufora
       └─ (blockStreamingBreak=message_end)
            └─ chunker opróżnia przy message_end
                   └─ wysyłka kanału (odpowiedzi blokowe)

• text_delta/events: zdarzenia strumienia modelu (mogą być rzadkie dla modeli bez strumieniowania).
• chunker: EmbeddedBlockChunker stosujący dolne/górne granice + preferencję podziału.
• channel send: rzeczywiste wiadomości wychodzące (odpowiedzi blokowe).

• agents.defaults.blockStreamingDefault: "on"/"off" (domyślnie wyłączone).
• Nadpisania kanałów: *.blockStreaming (oraz warianty per konto), aby wymusić "on"/"off" dla kanału.
• agents.defaults.blockStreamingBreak: "text_end" lub "message_end".
• agents.defaults.blockStreamingChunk: { minChars, maxChars, breakPreference? }.
• agents.defaults.blockStreamingCoalesce: { minChars?, maxChars?, idleMs? } (scala strumieniowane bloki przed wysłaniem).
• Twardy limit kanału: *.textChunkLimit (np. channels.whatsapp.textChunkLimit).
• Tryb dzielenia kanału na fragmenty: *.chunkMode (length domyślnie, newline dzieli po pustych liniach (granice akapitów) przed dzieleniem według długości).
• Miękki limit Discord: channels.discord.maxLinesPerMessage (domyślnie 17) dzieli wysokie odpowiedzi, aby uniknąć obcięcia w UI.

• text_end: przesyłaj bloki, gdy tylko chunker je wyemituje; opróżniaj przy każdym text_end.
• message_end: czekaj, aż wiadomość asystenta się zakończy, a następnie opróżnij zbuforowane dane wyjściowe.

​

Algorytm dzielenia na fragmenty (dolne/górne granice)

• Dolna granica: nie emituj, dopóki bufor nie osiągnie >= minChars (chyba że wymuszono).
• Górna granica: preferuj podziały przed maxChars; jeśli wymuszono, podziel przy maxChars.
• Preferencja podziału: paragraph → newline → sentence → whitespace → twardy podział.
• Bloki kodu: nigdy nie dziel wewnątrz bloków; przy wymuszeniu przy maxChars zamknij i otwórz ponownie blok, aby zachować poprawność Markdown.

​

Scalanie (łączenie strumieniowanych bloków)

• Scalanie czeka na przerwy bezczynności (idleMs) przed opróżnieniem.
• Bufory są ograniczane przez maxChars i zostaną opróżnione po przekroczeniu tego limitu.
• minChars zapobiega wysyłaniu małych fragmentów, dopóki nie zbierze się wystarczająco dużo tekstu (końcowe opróżnienie zawsze wysyła pozostały tekst).
• Łącznik jest wyprowadzany z blockStreamingChunk.breakPreference (paragraph → \n\n, newline → \n, sentence → spacja).
• Nadpisania kanałów są dostępne przez *.blockStreamingCoalesce (w tym konfiguracje per konto).
• Domyślne minChars dla scalania jest zwiększane do 1500 dla Signal/Slack/Discord, chyba że zostanie nadpisane.

​

Bardziej naturalne tempo między blokami

• Konfiguracja: agents.defaults.humanDelay (nadpisanie per agent przez agents.list[].humanDelay).
• Tryby: off (domyślnie), natural (800–2500ms), custom (minMs/maxMs).
• Dotyczy tylko odpowiedzi blokowych, a nie odpowiedzi końcowych ani podsumowań narzędzi.

​

„Przesyłaj fragmenty strumieniowo albo wszystko”

• Przesyłaj fragmenty strumieniowo: blockStreamingDefault: "on" + blockStreamingBreak: "text_end" (emituj na bieżąco). Kanały inne niż Telegram wymagają także *.blockStreaming: true.
• Przesyłaj wszystko na końcu: blockStreamingBreak: "message_end" (opróżnij raz, ewentualnie w wielu fragmentach, jeśli odpowiedź jest bardzo długa).
• Brak strumieniowania blokowego: blockStreamingDefault: "off" (tylko odpowiedź końcowa).

​

Tryby strumieniowania podglądu

• off: wyłącz strumieniowanie podglądu.
• partial: pojedynczy podgląd zastępowany najnowszym tekstem.
• block: aktualizacje podglądu w krokach dzielonych na fragmenty/dopisywanych.
• progress: podgląd postępu/stanu podczas generowania, końcowa odpowiedź po zakończeniu.

​

Mapowanie kanałów

• channels.slack.nativeStreaming przełącza natywne wywołania API strumieniowania Slack, gdy streaming=partial (domyślnie: true).

• Telegram: streamMode + logiczne streaming są automatycznie migrowane do enum streaming.
• Discord: streamMode + logiczne streaming są automatycznie migrowane do enum streaming.
• Slack: streamMode jest automatycznie migrowane do enum streaming; logiczne streaming jest automatycznie migrowane do nativeStreaming.

​

Zachowanie w czasie działania

• Używa aktualizacji podglądu sendMessage + editMessageText w wiadomościach prywatnych i grupach/tematach.
• Strumieniowanie podglądu jest pomijane, gdy strumieniowanie blokowe Telegram jest jawnie włączone (aby uniknąć podwójnego strumieniowania).
• /reasoning stream może zapisywać rozumowanie do podglądu.

• Używa wysyłania + edycji wiadomości podglądu.
• Tryb block używa dzielenia szkicu na fragmenty (draftChunk).
• Strumieniowanie podglądu jest pomijane, gdy strumieniowanie blokowe Discord jest jawnie włączone.

• partial może używać natywnego strumieniowania Slack (chat.startStream/append/stop), gdy jest dostępne.
• block używa podglądów szkicu w stylu dopisywania.
• progress używa tekstu podglądu stanu, a następnie końcowej odpowiedzi.

​

Powiązane

• Messages — cykl życia wiadomości i dostarczanie
• Retry — zachowanie przy ponowieniu po błędzie dostarczenia
• Channels — obsługa strumieniowania per kanał