diff --git a/src/main/java/io/socket/client/Manager.java b/src/main/java/io/socket/client/Manager.java index 6da92ee..1058b06 100644 --- a/src/main/java/io/socket/client/Manager.java +++ b/src/main/java/io/socket/client/Manager.java @@ -191,6 +191,10 @@ public class Manager extends Emitter { return this; } + public boolean isReconnecting() { + return reconnecting; + } + public int reconnectionAttempts() { return this._reconnectionAttempts; } diff --git a/src/main/java/io/socket/client/Socket.java b/src/main/java/io/socket/client/Socket.java index 61baef3..369d624 100644 --- a/src/main/java/io/socket/client/Socket.java +++ b/src/main/java/io/socket/client/Socket.java @@ -136,7 +136,7 @@ public class Socket extends Emitter { EventThread.exec(new Runnable() { @Override public void run() { - if (Socket.this.connected) return; + if (Socket.this.connected || Socket.this.io.isReconnecting()) return; Socket.this.subEvents(); Socket.this.io.open(); // ensure open