From 00eac14a017e9581d32b45f8df970263fa6948f5 Mon Sep 17 00:00:00 2001 From: Kushtrim Pacaj Date: Mon, 1 Apr 2019 00:26:16 +0200 Subject: [PATCH] Don't process socket.connect() if we are already re-connecting. --- src/main/java/io/socket/client/Manager.java | 4 ++++ src/main/java/io/socket/client/Socket.java | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/io/socket/client/Manager.java b/src/main/java/io/socket/client/Manager.java index 6da92ee5..1058b067 100644 --- a/src/main/java/io/socket/client/Manager.java +++ b/src/main/java/io/socket/client/Manager.java @@ -191,6 +191,10 @@ public Manager reconnection(boolean v) { 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 61baef35..369d6244 100644 --- a/src/main/java/io/socket/client/Socket.java +++ b/src/main/java/io/socket/client/Socket.java @@ -136,7 +136,7 @@ public Socket open() { 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