diff --git a/Source/SocketEngine.swift b/Source/SocketEngine.swift
index f22f73f..17f2b5c 100644
--- a/Source/SocketEngine.swift
+++ b/Source/SocketEngine.swift
@@ -279,8 +279,8 @@ public final class SocketEngine : NSObject, SocketEnginePollable, SocketEngineWe
         
         DefaultSocketLogger.Logger.log("Engine is being closed.", type: logType)
         
-        if closed {
-            client?.engineDidClose(reason)
+        if closed || !connected {
+            postSendClose(nil, nil, nil)
             return
         }
         
@@ -334,7 +334,7 @@ public final class SocketEngine : NSObject, SocketEnginePollable, SocketEngineWe
         guard let ws = self.ws else { return }
         
         for msg in postWait {
-            ws.writeString(fixDoubleUTF8(msg))
+            ws.writeString(msg)
         }
         
         postWait.removeAll(keepCapacity: true)