​

البث + التجزئة

• بث الكتل (القنوات): إصدار كتل مكتملة أثناء كتابة المساعد. وهذه رسائل قنوات عادية (وليست فروق رموز token deltas).
• بث المعاينة (Telegram/Discord/Slack): تحديث رسالة معاينة مؤقتة أثناء التوليد.

​

بث الكتل (رسائل القنوات)

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: أحداث تدفق النموذج (وقد تكون متفرقة في النماذج غير المتدفقة).
• chunker: ‏EmbeddedBlockChunker الذي يطبق حدودًا دنيا/عليا + تفضيل نقاط الانقطاع.
• channel send: الرسائل الصادرة الفعلية (ردود الكتل).

• agents.defaults.blockStreamingDefault: ‏"on"/"off" (الافتراضي off).
• تجاوزات القنوات: ‏*.blockStreaming (ومتغيرات لكل حساب) لفرض "on"/"off" لكل قناة.
• agents.defaults.blockStreamingBreak: ‏"text_end" أو "message_end".
• agents.defaults.blockStreamingChunk: ‏{ minChars, maxChars, breakPreference? }.
• agents.defaults.blockStreamingCoalesce: ‏{ minChars?, maxChars?, idleMs? } (دمج الكتل المتدفقة قبل الإرسال).
• الحد الصارم للقناة: ‏*.textChunkLimit (مثل channels.whatsapp.textChunkLimit).
• وضع تجزئة القناة: ‏*.chunkMode (length افتراضيًا، وnewline يقسم عند الأسطر الفارغة (حدود الفقرات) قبل التجزئة حسب الطول).
• الحد المرن لـ Discord: ‏channels.discord.maxLinesPerMessage (الافتراضي 17) يقسم الردود الطويلة رأسيًا لتجنب قص واجهة المستخدم.

• text_end: بث الكتل بمجرد أن يصدرها chunker؛ والتفريغ عند كل text_end.
• message_end: الانتظار حتى تنتهي رسالة المساعد، ثم تفريغ المخرجات المخزنة.

​

خوارزمية التجزئة (الحدود الدنيا/العليا)

• الحد الأدنى: لا تُصدر شيئًا حتى يصبح المخزن >= minChars (ما لم يكن ذلك إجباريًا).
• الحد الأعلى: يُفضَّل التقسيم قبل maxChars؛ وإذا كان ذلك إجباريًا، فيتم التقسيم عند maxChars.
• تفضيل نقطة الانقطاع: paragraph → newline → sentence → whitespace → انقطاع صارم.
• أسوار الشيفرة: لا يتم أبدًا التقسيم داخل الأسوار؛ وعند الإجبار عند maxChars، يتم إغلاق السياج ثم إعادة فتحه للحفاظ على صحة Markdown.

​

الدمج (دمج الكتل المتدفقة)

• ينتظر الدمج فجوات الخمول (idleMs) قبل التفريغ.
• تُحدَّد المخازن بـ maxChars وسيتم تفريغها إذا تجاوزته.
• يمنع minChars إرسال الأجزاء الصغيرة جدًا حتى يتراكم مقدار كافٍ من النص (ويُرسل التفريغ النهائي دائمًا النص المتبقي).
• يُشتق الموصل من blockStreamingChunk.breakPreference (paragraph → \n\n، newline → \n، sentence → مسافة).
• تتوفر تجاوزات القنوات عبر *.blockStreamingCoalesce (بما في ذلك إعدادات لكل حساب).
• يتم رفع القيمة الافتراضية لـ coalesce minChars إلى 1500 في Signal/Slack/Discord ما لم يتم تجاوزها.

​

الإيقاع الشبيه بالبشر بين الكتل

• الإعداد: agents.defaults.humanDelay (يمكن تجاوزه لكل وكيل عبر agents.list[].humanDelay).
• الأوضاع: off (الافتراضي)، natural ‏(800–2500ms)، custom ‏(minMs/maxMs).
• ينطبق فقط على ردود الكتل، وليس الردود النهائية أو ملخصات الأدوات.

​

”بث الأجزاء أم كل شيء”

• بث الأجزاء: ‏blockStreamingDefault: "on" + ‏blockStreamingBreak: "text_end" (إصدار أثناء التقدم). كما تحتاج القنوات غير Telegram أيضًا إلى *.blockStreaming: true.
• بث كل شيء في النهاية: ‏blockStreamingBreak: "message_end" (تفريغ مرة واحدة، وربما عدة أجزاء إذا كان طويلًا جدًا).
• لا يوجد بث كتل: ‏blockStreamingDefault: "off" (الرد النهائي فقط).

​

أوضاع بث المعاينة

• off: تعطيل بث المعاينة.
• partial: معاينة واحدة يتم استبدالها بأحدث نص.
• block: تحديثات معاينة مجزأة/ملحقة.
• progress: معاينة تقدم/حالة أثناء التوليد، ثم الإجابة النهائية عند الاكتمال.

​

ربط القنوات

• يبدّل channels.slack.nativeStreaming استدعاءات API الخاصة بالبث الأصلي في Slack عندما تكون streaming=partial (الافتراضي: true).

• Telegram: تتم الترحيل التلقائي لـ streamMode وboolean streaming إلى enum streaming.
• Discord: تتم الترحيل التلقائي لـ streamMode وboolean streaming إلى enum streaming.
• Slack: تتم الترحيل التلقائي لـ streamMode إلى enum streaming؛ وتتم الترحيل التلقائي لـ boolean streaming إلى nativeStreaming.

​

سلوك وقت التشغيل

• يستخدم sendMessage + editMessageText لتحديثات المعاينة عبر الرسائل المباشرة والمجموعات/الموضوعات.
• يتم تخطي بث المعاينة عندما يكون بث كتل Telegram مفعّلًا صراحةً (لتجنب البث المزدوج).
• يمكن لـ /reasoning stream كتابة الاستدلال في المعاينة.

• يستخدم رسائل معاينة من نوع send + edit.
• يستخدم وضع block تجزئة المسودة (draftChunk).
• يتم تخطي بث المعاينة عندما يكون بث كتل Discord مفعّلًا صراحةً.

• يمكن أن يستخدم partial البث الأصلي في Slack (chat.startStream/append/stop) عندما يكون متاحًا.
• يستخدم block معاينات مسودة بنمط الإلحاق.
• يستخدم progress نص معاينة للحالة، ثم الإجابة النهائية.

​

ذو صلة

• الرسائل — دورة حياة الرسالة وتسليمها
• إعادة المحاولة — سلوك إعادة المحاولة عند فشل التسليم
• القنوات — دعم البث لكل قناة