diff --git a/angular2-websocket.js b/angular2-websocket.js index 298ef0a..99df094 100644 --- a/angular2-websocket.js +++ b/angular2-websocket.js @@ -98,7 +98,7 @@ var $WebSocket = (function () { $WebSocket.prototype.fireQueue = function () { while (this.sendQueue.length && this.socket.readyState === this.readyStateConstants.OPEN) { var data = this.sendQueue.shift(); - this.socket.send(lang_1.isString(data.message) ? data.message : JSON.stringify(data.message)); + this.socket.send(data.message); } }; $WebSocket.prototype.notifyCloseCallbacks = function (event) { @@ -206,4 +206,4 @@ var $WebSocket = (function () { return $WebSocket; }()); exports.$WebSocket = $WebSocket; -//# sourceMappingURL=angular2-websocket.js.map \ No newline at end of file +//# sourceMappingURL=angular2-websocket.js.map diff --git a/src/angular2-websocket.ts b/src/angular2-websocket.ts index 4039968..1a01c91 100644 --- a/src/angular2-websocket.ts +++ b/src/angular2-websocket.ts @@ -98,9 +98,7 @@ export class $WebSocket { while (this.sendQueue.length && this.socket.readyState === this.readyStateConstants.OPEN) { var data = this.sendQueue.shift(); - this.socket.send( - isString(data.message) ? data.message : JSON.stringify(data.message) - ); + this.socket.send(data.message); // data.deferred.resolve(); } }