diff options
Diffstat (limited to 'lib/websocket.js')
-rw-r--r-- | lib/websocket.js | 74 |
1 files changed, 37 insertions, 37 deletions
diff --git a/lib/websocket.js b/lib/websocket.js index 5c64d28f3..8ccb3d40b 100644 --- a/lib/websocket.js +++ b/lib/websocket.js @@ -24,50 +24,50 @@ var WebSocket = require('ws'); // jshint ignore:line -var WebSocketProvider = function(host) { - // onmessage handlers - this.handlers = []; - // queue will be filled with messages if send is invoked before the ws is ready - this.queued = []; - this.ready = false; + var WebSocketProvider = function(host) { + // onmessage handlers + this.handlers = []; + // queue will be filled with messages if send is invoked before the ws is ready + this.queued = []; + this.ready = false; - this.ws = new WebSocket(host); + this.ws = new WebSocket(host); - var self = this; - this.ws.onmessage = function(event) { - for(var i = 0; i < self.handlers.length; i++) { - self.handlers[i].call(self, JSON.parse(event.data), event); - } - }; + var self = this; + this.ws.onmessage = function(event) { + for(var i = 0; i < self.handlers.length; i++) { + self.handlers[i].call(self, JSON.parse(event.data), event); + } + }; - this.ws.onopen = function() { - self.ready = true; + this.ws.onopen = function() { + self.ready = true; - for(var i = 0; i < self.queued.length; i++) { - // Resend - self.send(self.queued[i]); - } + for(var i = 0; i < self.queued.length; i++) { + // Resend + self.send(self.queued[i]); + } + }; }; -}; -WebSocketProvider.prototype.send = function(payload) { - if(this.ready) { - var data = JSON.stringify(payload); + WebSocketProvider.prototype.send = function(payload) { + if(this.ready) { + var data = JSON.stringify(payload); - this.ws.send(data); - } else { - this.queued.push(payload); - } -}; + this.ws.send(data); + } else { + this.queued.push(payload); + } + }; -WebSocketProvider.prototype.onMessage = function(handler) { - this.handlers.push(handler); -}; + WebSocketProvider.prototype.onMessage = function(handler) { + this.handlers.push(handler); + }; -WebSocketProvider.prototype.unload = function() { - this.ws.close(); -}; -Object.defineProperty(WebSocketProvider.prototype, "onmessage", { - set: function(provider) { this.onMessage(provider); } -}); + WebSocketProvider.prototype.unload = function() { + this.ws.close(); + }; + Object.defineProperty(WebSocketProvider.prototype, "onmessage", { + set: function(provider) { this.onMessage(provider); } + }); module.exports = WebSocketProvider; |