Ana içeriğe atla

​
Streaming + parçalama

OpenClaw’da iki ayrı “streaming” katmanı vardır:
  • Blok streaming (kanallar): asistan yazdıkça tamamlanmış blokları yayar. Bunlar normal kanal mesajlarıdır (token deltaları değildir).
  • Token-benzeri streaming (yalnızca Telegram): üretim sırasında taslak baloncuğu kısmi metinle günceller; son mesaj en sonda gönderilir.
Günümüzde harici kanal mesajlarına gerçek token streaming yoktur. Telegram taslak streaming’i tek kısmi-stream yüzeyidir.

​
Blok streaming (kanal mesajları)

Blok streaming, asistan çıktısını kullanılabilir oldukça kaba parçalara bölerek gönderir. 
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)
Legend:
  • text_delta/events: model stream olayları (streaming olmayan modellerde seyrek olabilir).
  • chunker: min/max sınırları + bölme tercihini uygulayan EmbeddedBlockChunker.
  • channel send: gerçek giden mesajlar (blok yanıtlar).
Kontroller:
  • agents.defaults.blockStreamingDefault: "on"/"off" (varsayılan kapalı).
  • Kanal geçersiz kılmaları: kanal başına "on"/"off" zorlamak için *.blockStreaming (ve hesap başına varyantlar).
  • agents.defaults.blockStreamingBreak: "text_end" veya "message_end".
  • agents.defaults.blockStreamingChunk: { minChars, maxChars, breakPreference? }.
  • agents.defaults.blockStreamingCoalesce: { minChars?, maxChars?, idleMs? } (göndermeden önce stream edilen blokları birleştir).
  • Kanal sert sınırı: *.textChunkLimit (örn. channels.whatsapp.textChunkLimit).
  • Kanal parça modu: *.chunkMode (length varsayılan, newline uzunlukla parçalamadan önce boş satırlarda (paragraf sınırları) böler).
  • Discord yumuşak sınırı: channels.discord.maxLinesPerMessage (varsayılan 17) UI kırpılmasını önlemek için uzun yanıtları böler.
Sınır semantiği:
  • text_end: parçalayıcı yayınladığı anda stream blokları gönder; her text_end’da flush et.
  • message_end: asistan mesajı bitene kadar bekle, ardından arabelleğe alınan çıktıyı gönder.
message_end, arabelleğe alınan metin maxChars’yi aşarsa yine parçalayıcıyı kullanır; bu nedenle sonunda birden fazla parça gönderebilir.

​
Parçalama algoritması (alt/üst sınırlar)

Blok parçalama EmbeddedBlockChunker tarafından uygulanır:
  • Alt sınır: arabellek >= minChars olana kadar gönderme (zorlanmadıkça).
  • Üst sınır: maxChars’den önce bölmeyi tercih et; zorlanırsa maxChars’te böl.
  • Bölme tercihi: paragraph → newline → sentence → whitespace → sert bölme.
  • Kod çitleri: çitlerin içinde asla bölme; maxChars’te zorlanırsa Markdown geçerli kalsın diye çiti kapat + yeniden aç.
maxChars, kanal textChunkLimit’ına sıkıştırılır; yani kanal başına sınırları aşamazsınız.

​
Birleştirme (stream edilen blokları birleştir)

Blok streaming etkin olduğunda OpenClaw, göndermeden önce ardışık blok parçalarını birleştirebilir. Bu, ilerlemeli çıktı sağlarken “tek satırlık spam”i azaltır.
  • Birleştirme, flush etmeden önce boşta kalma aralıklarını (idleMs) bekler.
  • Arabellekler maxChars ile sınırlandırılır ve aşılırsa gönderilir.
  • minChars, yeterli metin birikene kadar çok küçük parçaların gönderilmesini engeller (son flush her zaman kalan metni gönderir).
  • Birleştirici, blockStreamingChunk.breakPreference’ten türetilir (paragraph → \n\n, newline → \n, sentence → boşluk).
  • Kanal geçersiz kılmaları *.blockStreamingCoalesce üzerinden kullanılabilir (hesap başına yapılandırmalar dahil).
  • Varsayılan birleştirme minChars, Signal/Slack/Discord için geçersiz kılınmadıkça 1500’e yükseltilir.

​
Bloklar arasında insan benzeri tempo

Blok streaming etkin olduğunda, blok yanıtları arasında (ilk bloktan sonra) rastgele bir duraklama ekleyebilirsiniz. Bu, çok baloncuklu yanıtların daha doğal hissetmesini sağlar.
  • Yapılandırma: agents.defaults.humanDelay (ajan başına agents.list[].humanDelay ile geçersiz kılınabilir).
  • Modlar: off (varsayılan), natural (800–2500ms), custom (minMs/maxMs).
  • Yalnızca blok yanıtları için geçerlidir; final yanıtlar veya araç özetleri için geçerli değildir.

​
“Parçaları stream et veya her şeyi gönder”

This maps to:
  • Parçaları stream et: blockStreamingDefault: "on" + blockStreamingBreak: "text_end" (ilerledikçe gönder). Telegram dışı kanallar ayrıca *.blockStreaming: true gerektirir.
  • Her şeyi sonda stream et: blockStreamingBreak: "message_end" (bir kez flush et; çok uzunsa birden fazla parça olabilir).
  • Blok streaming yok: blockStreamingDefault: "off" (yalnızca final yanıt).
Kanal notu: Telegram dışı kanallar için blok streaming, *.blockStreaming açıkça true olarak ayarlanmadıkça kapalıdır. Telegram, blok yanıtlar olmadan taslakları stream edebilir (channels.telegram.streamMode). Yapılandırma konumu hatırlatıcısı: blockStreaming* varsayılanları kök yapılandırmada değil, agents.defaults altında bulunur.

​
Telegram taslak streaming (token-benzeri)

Telegram, taslak streaming’e sahip tek kanaldır:
  • Bot API sendMessage (ilk güncelleme) + editMessageText (sonraki güncellemeler) kullanır.
  • channels.telegram.streamMode: "partial" | "block" | "off".
    • partial: en son stream metniyle taslak güncellemeleri.
    • block: parçalı bloklar halinde taslak güncellemeleri (aynı parçalayıcı kuralları).
    • off: taslak streaming yok.
  • Taslak parça yapılandırması (yalnızca streamMode: "block" için): channels.telegram.draftChunk (varsayılanlar: minChars: 200, maxChars: 800).
  • Önizleme akışı, blok akışından ayrıdır.
  • Taslak streaming etkin olduğunda, OpenClaw çift streaming’i önlemek için o yanıt için blok streaming’i devre dışı bırakır.
  • Yalnızca metin içeren nihai yanıtlar, önizleme mesajı yerinde düzenlenerek uygulanır.
  • Metin dışı/karmaşık nihai yanıtlar normal nihai mesaj gönderimine geri döner.
  • /reasoning stream, akıl yürütmeyi canlı önizlemeye yazar (yalnızca Telegram).
Telegram (private + topics)
  └─ sendMessageDraft (draft bubble)
       ├─ streamMode=partial → update latest text
       └─ streamMode=block   → chunker updates draft
  └─ final reply → normal message
Legend:
  • preview message: üretim sırasında güncellenen geçici Telegram mesajı.
  • final edit: aynı önizleme mesajı üzerinde yerinde düzenleme (yalnızca metin).