set readyState when closing Manager
This commit is contained in:
@@ -165,7 +165,7 @@ public class Manager extends Emitter {
|
|||||||
EventThread.exec(new Runnable() {
|
EventThread.exec(new Runnable() {
|
||||||
@Override
|
@Override
|
||||||
public void run() {
|
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 com.github.nkzawa.engineio.client.Socket socket = Manager.this.engine;
|
||||||
final Manager self = Manager.this;
|
final Manager self = Manager.this;
|
||||||
@@ -314,14 +314,15 @@ public class Manager extends Emitter {
|
|||||||
private void close() {
|
private void close() {
|
||||||
this.skipReconnect = true;
|
this.skipReconnect = true;
|
||||||
this.cleanup();
|
this.cleanup();
|
||||||
|
this.readyState = ReadyState.CLOSED;
|
||||||
this.engine.close();
|
this.engine.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
private void onclose() {
|
private void onclose() {
|
||||||
this.cleanup();
|
this.cleanup();
|
||||||
|
this.readyState = ReadyState.CLOSED;
|
||||||
if (!this.skipReconnect) {
|
if (!this.skipReconnect) {
|
||||||
this.reconnect();
|
this.reconnect();
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user