Sha256: 940be1d8c3cedade4f8ea3b9e85c22633eb3706dffd413656dfc5c5b43e19042
Contents?: true
Size: 1.76 KB
Versions: 3
Compression:
Stored size: 1.76 KB
Contents
/*
WebSocket Interface for the WebSocketRails client.
*/
(function() {
var __bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; };
WebSocketRails.WebSocketConnection = (function() {
function WebSocketConnection(url, dispatcher) {
this.url = url;
this.dispatcher = dispatcher;
this.flush_queue = __bind(this.flush_queue, this);
this.on_close = __bind(this.on_close, this);
this.on_message = __bind(this.on_message, this);
this.trigger = __bind(this.trigger, this);
if (!this.url.match(/^wss?:\/\//)) {
this.url = "ws://" + this.url;
}
this.message_queue = [];
this._conn = new WebSocket(this.url);
this._conn.onmessage = this.on_message;
this._conn.onclose = this.on_close;
}
WebSocketConnection.prototype.trigger = function(event) {
if (this.dispatcher.state !== 'connected') {
return this.message_queue.push(event);
} else {
return this._conn.send(event.serialize());
}
};
WebSocketConnection.prototype.on_message = function(event) {
var data;
data = JSON.parse(event.data);
return this.dispatcher.new_message(data);
};
WebSocketConnection.prototype.on_close = function(event) {
var close_event;
close_event = new WebSocketRails.Event(['connection_closed', {}]);
return this.dispatcher.dispatch(close_event);
};
WebSocketConnection.prototype.flush_queue = function() {
var event, _i, _len, _ref;
_ref = this.message_queue;
for (_i = 0, _len = _ref.length; _i < _len; _i++) {
event = _ref[_i];
this._conn.send(event.serialize());
}
return this.message_queue = [];
};
return WebSocketConnection;
})();
}).call(this);
Version data entries
3 entries across 3 versions & 1 rubygems