Skip to content

Commit f3d92f9

Browse files
committed
polling-xhr: always close body
1 parent 75da2ea commit f3d92f9

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

src/main/java/io/socket/engineio/client/transports/PollingXHR.java

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import okhttp3.OkHttpClient;
2121
import okhttp3.RequestBody;
2222
import okhttp3.Response;
23+
import okhttp3.ResponseBody;
2324

2425
public class PollingXHR extends Polling {
2526

@@ -196,10 +197,14 @@ public void onResponse(Call call, Response response) throws IOException {
196197
self.response = response;
197198
self.onResponseHeaders(response.headers().toMultimap());
198199

199-
if (response.isSuccessful()) {
200-
self.onLoad();
201-
} else {
202-
self.onError(new IOException(Integer.toString(response.code())));
200+
try {
201+
if (response.isSuccessful()) {
202+
self.onLoad();
203+
} else {
204+
self.onError(new IOException(Integer.toString(response.code())));
205+
}
206+
} finally {
207+
response.close();
203208
}
204209
}
205210
});

0 commit comments

Comments
 (0)