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