diff --git a/src/main/java/io/socket/engineio/client/transports/WebSocket.java b/src/main/java/io/socket/engineio/client/transports/WebSocket.java index 3447494..22bfee0 100644 --- a/src/main/java/io/socket/engineio/client/transports/WebSocket.java +++ b/src/main/java/io/socket/engineio/client/transports/WebSocket.java @@ -190,6 +190,9 @@ public class WebSocket extends Transport { } else if (packet instanceof byte[]) { self.ws.sendMessage(RequestBody.create(BINARY, (byte[]) packet)); } + } catch (IllegalStateException e) { + logger.fine("websocket closed before we could write"); + doClose(); } catch (IOException e) { logger.fine("websocket closed before onclose event"); doClose();