ts streaming

app.py

@@ -21,10 +21,14 @@ def generate_streaming_wrapper(query: str, context: str):
     # Convert async generator to sync generator
     async_gen = _async_generator()
     
+    # Accumulate chunks for Gradio streaming
+    accumulated_text = ""
+    
     while True:
         try:
             chunk = loop.run_until_complete(async_gen.__anext__())
-            yield chunk
+            accumulated_text += chunk
+            yield accumulated_text  # Yield the accumulated text, not just the chunk
         except StopAsyncIteration:
             break