Sha256: 025ead05298755f1aa2dcea021131c374de2d48be3f216d66e80b1b3acd080ca
Contents?: true
Size: 1.57 KB
Versions: 6
Compression:
Stored size: 1.57 KB
Contents
var CometIO = function(){
new EventEmitter().apply(this);
this.url = "<%= cometio_url %>";
this.session = null;
var running = false;
var self = this;
this.push = function(type, data){
$.ajax(
{
url : self.url,
data : {type : type, data : data, session : self.session},
success : function(data){
},
error : function(req, stat, e){
self.emit("error", "CometIO push error");
},
complete : function(e){
},
type : "POST",
dataType : "json",
timeout : 10000
}
);
};
this.connect = function(){
if(running) return self;
self.on("__session_id", function(session){
self.session = session;
self.emit("connect", self.session);
});
running = true;
self.get();
return self;
};
this.close = function(){
running = false;
self.removeListener("__session_id");
};
this.get = function(){
if(!running) return;
$.ajax(
{
url : self.url,
data : {session : self.session},
success : function(data_arr){
for(var i = 0; i < data_arr.length; i++){
var data = data_arr[i];
if(data) self.emit(data.type, data.data);
}
self.get();
},
error : function(req, stat, e){
self.emit("error", "CometIO get error");
setTimeout(self.get, 10000);
},
complete : function(e){
},
type : "GET",
dataType : "json",
timeout : <%= (CometIO.options[:timeout]+10)*1000 %>
}
);
};
};
Version data entries
6 entries across 6 versions & 1 rubygems