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."));