fix: streaming

This commit is contained in:
Han Xiao
2025-02-22 12:37:24 +08:00
parent a85eb82936
commit 86fb712b7b

View File

@@ -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 = '';