fix(pipe) on: memory lick

This commit is contained in:
coderaiser 2014-05-30 06:39:44 -04:00
parent df634234e0
commit a471f7dbaf

View file

@ -24,7 +24,7 @@
function create(params) {
var gzip, read, write, isFsWrite,
p = params,
func = Util.exec.ret(p.callback),
func = p.callback,
options = {
bufferSize: 4 * 1024
};
@ -71,11 +71,16 @@
}
function on(event, emitter, callback) {
var listeners = emitter.listeners(event),
indexOf = listeners.indexOf(callback);
var isSet,
listeners = emitter.listeners(event),
callbackStr = '' + callback;
if (!~indexOf)
emitter.once(event, callback);
isSet = listeners.some(function(func) {
return '' + func === callbackStr;
});
if (!isSet)
emitter.on(event, callback);
}
/**