diff --git a/src/main/java/io/socket/client/Socket.java b/src/main/java/io/socket/client/Socket.java index 70e35dd..05feff3 100644 --- a/src/main/java/io/socket/client/Socket.java +++ b/src/main/java/io/socket/client/Socket.java @@ -91,7 +91,9 @@ public class Socket extends Emitter { add(On.on(io, Manager.EVENT_ERROR, new Listener() { @Override public void call(Object... args) { - Socket.super.emit(EVENT_CONNECT_ERROR, args[0]); + if (!Socket.this.connected) { + Socket.super.emit(EVENT_CONNECT_ERROR, args[0]); + } } })); add(On.on(io, Manager.EVENT_CLOSE, new Listener() {