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 {