From 54b73114d19f33a78bec1ce99325893129f8a148 Mon Sep 17 00:00:00 2001
From: Kushtrim Pacaj <KushtrimPacaj@users.noreply.github.com>
Date: Thu, 10 Dec 2020 11:47:20 +0100
Subject: [PATCH] fix: don't process socket.connect() if we are already
 re-connecting (#577)

---
 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 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