> ## Documentation Index
> Fetch the complete documentation index at: https://openclaw.veiseule.ai/llms.txt
> Use this file to discover all available pages before exploring further.

# Streaming ve Parçalama

# 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).