aboutsummaryrefslogtreecommitdiffstats
path: root/lib/websocket.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/websocket.js')
-rw-r--r--lib/websocket.js74
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;