From 5d06d1c2640c6733e9f7a0214e003a913e1a0964 Mon Sep 17 00:00:00 2001
From: huangge1199 <huangge1199@hotmail.com>
Date: Sat, 17 May 2025 14:28:12 +0800
Subject: [PATCH] =?UTF-8?q?ChatClient=E8=BF=94=E5=9B=9E=E5=93=8D=E5=BA=94?=
 =?UTF-8?q?=EF=BC=9A=E6=B5=81=E5=BC=8F=E5=93=8D=E5=BA=94=EF=BC=9A=E8=BF=94?=
 =?UTF-8?q?=E5=9B=9EChatResponse?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../huangge1199/aiagent/controller/ResController.java  | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/main/java/com/huangge1199/aiagent/controller/ResController.java b/src/main/java/com/huangge1199/aiagent/controller/ResController.java
index 0cae6a2..01b7fb6 100644
--- a/src/main/java/com/huangge1199/aiagent/controller/ResController.java
+++ b/src/main/java/com/huangge1199/aiagent/controller/ResController.java
@@ -75,4 +75,14 @@ public class ResController {
                 .content();
         return R.ok(output);
     }
+
+    @PostMapping("/fluxChatRes")
+    @Operation(summary = "流式响应：返回ChatResponse")
+    public R<Flux<ChatResponse>> fluxChatRes(@RequestBody String question) {
+        Flux<ChatResponse> output = chatClient.prompt()
+                .user(question)
+                .stream()
+                .chatResponse();
+        return R.ok(output);
+    }
 }