feat: update stream

app.py

@@ -30,8 +30,10 @@ def respond(
 ):
     messages = [{"role": "system", "content": system_message}]
 
+    # 添加历史消息
     messages.extend(history)
     
+    # 添加当前用户消息
     messages.append({"role": "user", "content": message})
 
     headers = {
@@ -56,6 +58,7 @@ def respond(
     try:
         with requests.post(API_URL, headers=headers, json=data, stream=True) as r:
             if r.status_code == 200:
+                current_response = ""
                 for line in r.iter_lines():
                     if line:
                         line = line.decode('utf-8')
@@ -67,7 +70,8 @@ def respond(
                                     if 'content' in delta:
                                         content = delta['content']
                                         if content:
-                                            yield content
+                                            current_response += content
+                                            yield current_response
                             except json.JSONDecodeError as e:
                                 print(f"[ERROR] JSON decode error: {e}")
                                 continue