From aadb0746ce8a15ec9113c05ff27328e14b06f47c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=A8=E8=80=80=E5=AE=87?= <312904176@qq.com>
Date: Tue, 15 Apr 2025 14:34:08 +0800
Subject: [PATCH] =?UTF-8?q?[fit]=20=E6=8D=95=E8=8E=B7=E6=B5=81=E5=BC=8F?=
 =?UTF-8?q?=E8=B0=83=E7=94=A8=E6=8A=A5=E9=94=99=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../fit/http/client/support/TextStreamChoir.java          | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git a/framework/fit/java/fit-builtin/services/fit-http-classic/definition/src/main/java/modelengine/fit/http/client/support/TextStreamChoir.java b/framework/fit/java/fit-builtin/services/fit-http-classic/definition/src/main/java/modelengine/fit/http/client/support/TextStreamChoir.java
index ca868669..911e270a 100644
--- a/framework/fit/java/fit-builtin/services/fit-http-classic/definition/src/main/java/modelengine/fit/http/client/support/TextStreamChoir.java
+++ b/framework/fit/java/fit-builtin/services/fit-http-classic/definition/src/main/java/modelengine/fit/http/client/support/TextStreamChoir.java
@@ -10,6 +10,7 @@
 
 import modelengine.fit.http.client.HttpClassicClientRequest;
 import modelengine.fit.http.client.HttpClassicClientResponse;
+import modelengine.fit.http.client.HttpClientResponseException;
 import modelengine.fit.http.entity.TextEvent;
 import modelengine.fit.http.entity.TextEventStreamEntity;
 import modelengine.fitframework.flowable.Choir;
@@ -22,7 +23,6 @@
 import modelengine.fitframework.inspection.Nonnull;
 import modelengine.fitframework.util.LockUtils;
 import modelengine.fitframework.util.ObjectUtils;
-import modelengine.fitframework.util.StringUtils;
 
 import java.lang.reflect.Type;
 import java.util.ArrayDeque;
@@ -103,11 +103,7 @@ private void exchange() {
                         HTTP_SUCCESS_CODE_MAX,
                         true,
                         false)) {
-                    throw new IllegalStateException(StringUtils.format(
-                            "Failed to exchange text event stream. [uri={0}, statusCode={1}, reason={2}]",
-                            this.request.requestUri(),
-                            response.statusCode(),
-                            response.reasonPhrase()));
+                    throw new HttpClientResponseException(request, response);
                 }
                 TextEventStreamEntity entity = response.textEventStreamEntity()
                         .orElseThrow(() -> new IllegalStateException("No text event stream entity."));