diff --git a/src/main/java/io/socket/engineio/client/transports/Polling.java b/src/main/java/io/socket/engineio/client/transports/Polling.java index 9aa73cc..3ac62f2 100644 --- a/src/main/java/io/socket/engineio/client/transports/Polling.java +++ b/src/main/java/io/socket/engineio/client/transports/Polling.java @@ -114,7 +114,7 @@ abstract public class Polling extends Transport { Parser.DecodePayloadCallback callback = new Parser.DecodePayloadCallback() { @Override public boolean call(Packet packet, int index, int total) { - if (self.readyState == ReadyState.OPENING) { + if (self.readyState == ReadyState.OPENING && Packet.OPEN.equals(packet.type)) { self.onOpen(); }