​

Strumieniowanie + dzielenie na fragmenty

• Strumieniowanie bloków (kanały): emituje ukończone bloki, gdy asystent pisze. 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 bloków (wiadomości kanału)

Model output
  └─ text_delta/events
       ├─ (blockStreamingBreak=text_end)
       │    └─ chunker emits blocks as buffer grows
       └─ (blockStreamingBreak=message_end)
            └─ chunker flushes at message_end
                   └─ channel send (block replies)

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

• agents.defaults.blockStreamingDefault: "on"/"off" (domyślnie off).
• Nadpisania kanałów: *.blockStreaming (oraz warianty per konto), aby wymusić "on"/"off" dla każdego 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 długie odpowiedzi, aby uniknąć przycinania w interfejsie.

• text_end: strumieniuje bloki, gdy tylko chunker je wyemituje; opróżnia przy każdym text_end.
• message_end: czeka, aż wiadomość asystenta zostanie ukończona, a następnie opróżnia zbuforowane dane wyjściowe.

​

Algorytm dzielenia na fragmenty (dolna/górna granica)

• Dolna granica: nie emituje, dopóki bufor nie osiągnie minChars (chyba że zostanie wymuszone).
• Górna granica: preferuje podziały przed maxChars; jeśli wymuszone, dzieli przy maxChars.
• Preferencja podziału: paragraph → newline → sentence → whitespace → twardy podział.
• Bloki kodu: nigdy nie dzieli wewnątrz bloków; przy wymuszeniu na maxChars zamyka i ponownie otwiera blok, aby zachować poprawność Markdown.

​

Scalanie (łączenie strumieniowanych bloków)

• Scalanie czeka na przerwy bezczynności (idleMs) przed opróżnieniem.
• Bufory są ograniczone przez maxChars i zostaną opróżnione, jeśli go przekroczą.
• minChars zapobiega wysyłaniu bardzo małych fragmentów, dopóki nie zgromadzi się wystarczająco dużo tekstu (końcowe opróżnienie zawsze wysyła pozostały tekst).
• Separator łączenia 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.

​

Tempo zbliżone do ludzkiego 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, nie odpowiedzi końcowych ani podsumowań narzędzi.

​

”Strumieniuj fragmenty albo wszystko”

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

​

Tryby strumieniowania podglądu

• off: wyłącza strumieniowanie podglądu.
• partial: pojedynczy podgląd zastępowany najnowszym tekstem.
• block: aktualizacje podglądu wykonywane krokowo przez dzielenie na fragmenty/dodawanie.
• progress: podgląd postępu/statusu podczas generowania, odpowiedź końcowa po zakończeniu.

​

Mapowanie kanałów

• channels.slack.streaming.nativeTransport przełącza natywne wywołania API strumieniowania Slacka, gdy channels.slack.streaming.mode="partial" (domyślnie: true).
• Natywne strumieniowanie Slacka i status wątku asystenta Slack wymagają docelowego wątku odpowiedzi; wiadomości prywatne najwyższego poziomu nie pokazują takiego podglądu w stylu wątku.

• Telegram: streamMode + logiczne streaming są automatycznie migrowane do enuma streaming.
• Discord: streamMode + logiczne streaming są automatycznie migrowane do enuma streaming.
• Slack: streamMode jest automatycznie migrowane do streaming.mode; logiczne streaming jest automatycznie migrowane do streaming.mode plus streaming.nativeTransport; starsze nativeStreaming jest automatycznie migrowane do streaming.nativeTransport.

​

Zachowanie w czasie działania

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

• Używa wiadomości podglądu send + edit.
• Tryb block używa roboczego dzielenia na fragmenty (draftChunk).
• Strumieniowanie podglądu jest pomijane, gdy strumieniowanie bloków Discorda jest jawnie włączone.

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

​

Powiązane

• Wiadomości — cykl życia i dostarczanie wiadomości
• Ponawianie — zachowanie ponawiania przy błędzie dostarczenia
• Kanały — obsługa strumieniowania per kanał