@@ -988,7 +988,7 @@ protected <T> AsyncCompletionHandler<T> handle(final Class<T> clazz) {
988
988
public T onCompleted (Response response ) throws Exception {
989
989
logResponse (response );
990
990
if (isStatus2xx (response )) {
991
- return (T ) mapper .reader (clazz ).readValue (response .getResponseBodyAsBytes ());
991
+ return (T ) mapper .reader (clazz ).readValue (response .getResponseBodyAsStream ());
992
992
}
993
993
if (response .getStatusCode () == 404 ) {
994
994
return null ;
@@ -1004,7 +1004,7 @@ protected <T> AsyncCompletionHandler<T> handle(final Class<T> clazz, final Strin
1004
1004
public T onCompleted (Response response ) throws Exception {
1005
1005
logResponse (response );
1006
1006
if (isStatus2xx (response )) {
1007
- return mapper .convertValue (mapper .readTree (response .getResponseBodyAsBytes ()).get (name ), clazz );
1007
+ return mapper .convertValue (mapper .readTree (response .getResponseBodyAsStream ()).get (name ), clazz );
1008
1008
}
1009
1009
if (response .getStatusCode () == 404 ) {
1010
1010
return null ;
@@ -1021,7 +1021,7 @@ public List<T> onCompleted(Response response) throws Exception {
1021
1021
logResponse (response );
1022
1022
if (isStatus2xx (response )) {
1023
1023
List <T > values = new ArrayList <T >();
1024
- for (JsonNode node : mapper .readTree (response .getResponseBodyAsBytes ())) {
1024
+ for (JsonNode node : mapper .readTree (response .getResponseBodyAsStream ())) {
1025
1025
values .add (mapper .convertValue (node , clazz ));
1026
1026
}
1027
1027
return values ;
@@ -1038,7 +1038,7 @@ public List<T> onCompleted(Response response) throws Exception {
1038
1038
logResponse (response );
1039
1039
if (isStatus2xx (response )) {
1040
1040
List <T > values = new ArrayList <T >();
1041
- for (JsonNode node : mapper .readTree (response .getResponseBodyAsBytes ()).get (name )) {
1041
+ for (JsonNode node : mapper .readTree (response .getResponseBodyAsStream ()).get (name )) {
1042
1042
values .add (mapper .convertValue (node , clazz ));
1043
1043
}
1044
1044
return values ;
@@ -1055,7 +1055,7 @@ public List<SearchResultEntity> onCompleted(Response response) throws Exception
1055
1055
logResponse (response );
1056
1056
if (isStatus2xx (response )) {
1057
1057
List <SearchResultEntity > values = new ArrayList <SearchResultEntity >();
1058
- for (JsonNode node : mapper .readTree (response .getResponseBodyAsBytes ()).get (name )) {
1058
+ for (JsonNode node : mapper .readTree (response .getResponseBodyAsStream ()).get (name )) {
1059
1059
Class <? extends SearchResultEntity > clazz = searchResultTypes .get (node .get ("result_type" ));
1060
1060
if (clazz != null ) {
1061
1061
values .add (mapper .convertValue (node , clazz ));
0 commit comments