Skip to content

Commit ab93170

Browse files
committed
Merge branch '3.5.x'
2 parents 00cad8f + 8cfcb09 commit ab93170

File tree

1 file changed

+2
-6
lines changed
  • framework/fit/java/fit-builtin/services/fit-http-classic/definition/src/main/java/modelengine/fit/http/client/support

1 file changed

+2
-6
lines changed

framework/fit/java/fit-builtin/services/fit-http-classic/definition/src/main/java/modelengine/fit/http/client/support/TextStreamChoir.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010

1111
import modelengine.fit.http.client.HttpClassicClientRequest;
1212
import modelengine.fit.http.client.HttpClassicClientResponse;
13+
import modelengine.fit.http.client.HttpClientResponseException;
1314
import modelengine.fit.http.entity.TextEvent;
1415
import modelengine.fit.http.entity.TextEventStreamEntity;
1516
import modelengine.fitframework.flowable.Choir;
@@ -22,7 +23,6 @@
2223
import modelengine.fitframework.inspection.Nonnull;
2324
import modelengine.fitframework.util.LockUtils;
2425
import modelengine.fitframework.util.ObjectUtils;
25-
import modelengine.fitframework.util.StringUtils;
2626

2727
import java.lang.reflect.Type;
2828
import java.util.ArrayDeque;
@@ -103,11 +103,7 @@ private void exchange() {
103103
HTTP_SUCCESS_CODE_MAX,
104104
true,
105105
false)) {
106-
throw new IllegalStateException(StringUtils.format(
107-
"Failed to exchange text event stream. [uri={0}, statusCode={1}, reason={2}]",
108-
this.request.requestUri(),
109-
response.statusCode(),
110-
response.reasonPhrase()));
106+
throw new HttpClientResponseException(request, response);
111107
}
112108
TextEventStreamEntity entity = response.textEventStreamEntity()
113109
.orElseThrow(() -> new IllegalStateException("No text event stream entity."));

0 commit comments

Comments
 (0)