From 59586f76094a99b565a750a666985db45cc85a01 Mon Sep 17 00:00:00 2001 From: wzurita Date: Mon, 29 Aug 2016 23:50:01 +0200 Subject: [PATCH] Refactoring the cleanup method so it is called after the stream/reader is closed. Fixes #65 --- .../io/socket/engineio/client/transports/PollingXHR.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/src/main/java/io/socket/engineio/client/transports/PollingXHR.java b/src/main/java/io/socket/engineio/client/transports/PollingXHR.java index 2bec7cc..3a5df8e 100644 --- a/src/main/java/io/socket/engineio/client/transports/PollingXHR.java +++ b/src/main/java/io/socket/engineio/client/transports/PollingXHR.java @@ -229,7 +229,6 @@ public class PollingXHR extends Polling { private void onSuccess() { this.emit(EVENT_SUCCESS); - this.cleanup(); } private void onData(String data) { @@ -244,7 +243,6 @@ public class PollingXHR extends Polling { private void onError(Exception err) { this.emit(EVENT_ERROR, err); - this.cleanup(); } private void onRequestHeaders(Map> headers) { @@ -304,11 +302,9 @@ public class PollingXHR extends Polling { try { if (reader != null) reader.close(); } catch (IOException e) {} + this.cleanup(); } } - public void abort() { - this.cleanup(); - } public static class Options {