From 86fb712b7bf838a6abe3cc00d5b8d106281f1549 Mon Sep 17 00:00:00 2001
From: Han Xiao <han.xiao@jina.ai>
Date: Sat, 22 Feb 2025 12:37:24 +0800
Subject: [PATCH] fix: streaming

---
 src/app.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/app.ts b/src/app.ts
index 1456729..04382be 100644
--- a/src/app.ts
+++ b/src/app.ts
@@ -441,7 +441,7 @@ async function processQueue(streamingState: StreamingState, res: Response, reque
     } catch (error) {
       console.error('Error in streaming:', error);
     } finally {
-      // Reset state and remove from queue
+      // Clear state before moving to next item
       streamingState.isEmitting = false;
       streamingState.currentlyStreaming = false;
       streamingState.remainingContent = '';