diff --git a/src/main/java/com/github/nkzawa/socketio/client/Manager.java b/src/main/java/com/github/nkzawa/socketio/client/Manager.java index a3fdf64..1bb6187 100644 --- a/src/main/java/com/github/nkzawa/socketio/client/Manager.java +++ b/src/main/java/com/github/nkzawa/socketio/client/Manager.java @@ -165,7 +165,7 @@ public class Manager extends Emitter { EventThread.exec(new Runnable() { @Override public void run() { - if (Manager.this.readyState == ReadyState.OPEN && !Manager.this.reconnecting) return; + if (Manager.this.readyState == ReadyState.OPEN) return; final com.github.nkzawa.engineio.client.Socket socket = Manager.this.engine; final Manager self = Manager.this; @@ -314,14 +314,15 @@ public class Manager extends Emitter { private void close() { this.skipReconnect = true; this.cleanup(); + this.readyState = ReadyState.CLOSED; this.engine.close(); } private void onclose() { this.cleanup(); + this.readyState = ReadyState.CLOSED; if (!this.skipReconnect) { this.reconnect(); - } }