Comparing version 0.3.8 to 0.3.9
{ | ||
"name": "ricochet", | ||
"version": "0.3.8", | ||
"version": "0.3.9", | ||
"description": "Pub/Sub Framework for building robust TCP transport layers in node.js applications ", | ||
@@ -5,0 +5,0 @@ "main": "ricochet.js", |
@@ -47,2 +47,3 @@ 'use strict'; | ||
return self.sendMessage(data, function(err){ | ||
cb(err); | ||
if(err){ | ||
@@ -55,3 +56,2 @@ self.emit('sendError', { | ||
} | ||
return cb(err); | ||
}); | ||
@@ -61,2 +61,3 @@ }, this.config.queueSize); | ||
return self.receiveMessage(data, function(err){ | ||
cb(err); | ||
if(err){ | ||
@@ -69,3 +70,2 @@ self.emit('receiveError', { | ||
} | ||
return cb(err); | ||
}); | ||
@@ -274,2 +274,11 @@ }, this.config.queueSize); | ||
handler.inherit = function(event){ | ||
var self = this; | ||
handler.onAny(function(){ | ||
var args = Array.prototype.slice.call(arguments); | ||
args.unshift(this.event); | ||
event.emit.apply(self, args); | ||
}); | ||
}; | ||
var timeout = null; | ||
@@ -276,0 +285,0 @@ if(msg.headers.timeout){ |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
41085
966