'commit'

src/main/java/com/dsideal/base/Util/CallDeepSeek.java

@@ -142,11 +142,7 @@ public class CallDeepSeek {
                         }
                     } else {
                         System.out.println("收到结束标记 [DONE]");
-                    }
-                }
-            });
-
-            // 流结束后的处理
+                        // 收到[DONE]标记，流处理完成
                         String responseContent = fullResponse.toString();
                         System.out.println("流处理完成，总内容长度: " + responseContent.length());
                         if (saveToFile && outputPath != null) {
@@ -155,6 +151,12 @@ public class CallDeepSeek {
                         } else {
                             listener.onComplete(responseContent);
                         }
+                        return; // 提前结束处理
+                    }
+                }
+            });
+
+            System.out.println("SSE数据流处理结束");
         } else {
             System.err.println("API请求失败，状态码: " + response.statusCode());
             listener.onError("API请求失败: " + response.statusCode() + " Body: " + response.body().toString());