Update

Author: xdev-x

lib/socket.dart

@@ -13,7 +13,7 @@ class Socket implements SocketBase {
     _messages = _messageController.stream.asBroadcastStream();
     _ws = new WebSocket(url);
     _ws.onMessage.listen((e) {
-      var msg = new Message(e.data);
+      var msg = new Message.fromPacket(e.data);
       _messageController.add(msg);
     });
   }
@@ -34,4 +34,4 @@ class Socket implements SocketBase {
   void close([int status, String reason]) {
     _ws.close(status, reason);
   }
-}
+}

lib/src/socket.dart

@@ -9,7 +9,7 @@ class Socket implements SocketBase {
   Socket(this._ws) {
     _messages = _messageController.stream.asBroadcastStream();
     _ws.listen((data) {
-      var msg = new Message(data);
+      var msg = new Message.fromPacket(data);
       _messageController.add(msg);
     },
     onDone: () {