From e9c985a4878adc427b327e69b178bbe4928d2daa Mon Sep 17 00:00:00 2001
From: dobby-d-elf <dobby.the.agent@gmail.com>
Date: Mon, 11 May 2026 15:15:58 -0600
Subject: [PATCH] fix: make stream rAF cancellation explicit

---
 STREAMING_FADE_HANDOFF.md |  2 +-
 static/messages.js        | 12 ++++++------
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/STREAMING_FADE_HANDOFF.md b/STREAMING_FADE_HANDOFF.md
index ea3c8aeb..9596cf69 100644
--- a/STREAMING_FADE_HANDOFF.md
+++ b/STREAMING_FADE_HANDOFF.md
@@ -38,7 +38,7 @@ Added local fade state:
 Key helpers:
 
 - `_resetStreamFadeState()`
-- `_cancelPendingStreamRender()`
+- `_cancelAnimationFramePendingStreamRender()`
 - `_shouldUseStreamFade()`
 - `_streamFadeWordCountOf(text)`
 - `_streamFadeNextText(targetText)`
diff --git a/static/messages.js b/static/messages.js
index 9cdd6834..de00c253 100644
--- a/static/messages.js
+++ b/static/messages.js
@@ -695,7 +695,7 @@ function attachLiveStream(activeSid, streamId, uploaded=[], options={}){
     _streamFadeLatestAnimationEndAt=0;
     _streamFadeLastRevealCount=0;
   }
-  function _cancelPendingStreamRender(){
+  function _cancelAnimationFramePendingStreamRender(){
     if(_pendingRafHandle===null) return;
     cancelAnimationFrame(_pendingRafHandle);
     clearTimeout(_pendingRafHandle);
@@ -1197,7 +1197,7 @@ function attachLiveStream(activeSid, streamId, uploaded=[], options={}){
         // the DOM is settled by renderMessages, so no trailing token/reasoning rAF
         // can reintroduce a stale thinking card or duplicate content.
         _streamFinalized=true;
-        _cancelPendingStreamRender();
+        _cancelAnimationFramePendingStreamRender();
         if(typeof finalizeThinkingCard==='function') finalizeThinkingCard();
         // Finalize smd parser — flushes any remaining buffered markdown state
         // and runs Prism + copy buttons on the live segment before the DOM is replaced
@@ -1342,7 +1342,7 @@ function attachLiveStream(activeSid, streamId, uploaded=[], options={}){
         sendBrowserNotification('Response complete',assistantText?assistantText.slice(0,100):'Task finished');
       };
       if(_shouldUseStreamFade()&&assistantBody){
-        _cancelPendingStreamRender();
+        _cancelAnimationFramePendingStreamRender();
         _drainStreamFadeBeforeDone(_finishDone);
         return;
       }
@@ -1441,7 +1441,7 @@ function attachLiveStream(activeSid, streamId, uploaded=[], options={}){
       _terminalStateReached=true;
       if(_persistTimer){clearTimeout(_persistTimer);_persistTimer=null;}
       _streamFinalized=true;
-      _cancelPendingStreamRender();
+      _cancelAnimationFramePendingStreamRender();
       _smdEndParser();
       if(typeof finalizeThinkingCard==='function') finalizeThinkingCard();
       // Application-level error sent explicitly by the server (rate limit, crash, etc.)
@@ -1527,7 +1527,7 @@ function attachLiveStream(activeSid, streamId, uploaded=[], options={}){
       _terminalStateReached=true;
       if(_persistTimer){clearTimeout(_persistTimer);_persistTimer=null;}
       _streamFinalized=true;
-      _cancelPendingStreamRender();
+      _cancelAnimationFramePendingStreamRender();
       _smdEndParser();
       if(typeof finalizeThinkingCard==='function') finalizeThinkingCard();
       source.close();
@@ -1621,7 +1621,7 @@ function attachLiveStream(activeSid, streamId, uploaded=[], options={}){
     // cannot fire after renderMessages() has settled the DOM with the error message.
     if(_persistTimer){clearTimeout(_persistTimer);_persistTimer=null;}
     _streamFinalized=true;
-    _cancelPendingStreamRender();
+    _cancelAnimationFramePendingStreamRender();
     if(typeof finalizeThinkingCard==='function') finalizeThinkingCard();
     _clearOwnerInflightState();
     _closeSource();