fix(pipe) on: length -> indexOf

This commit is contained in:
coderaiser 2014-05-30 02:17:05 -04:00
parent c4714f66a0
commit aea9ad99e3

View file

@ -63,7 +63,7 @@
end: !p.notEnd
});
read.once('end', func);
on('end', read, func);
}, function(callback) {
on('open', write, callback);
});
@ -72,9 +72,9 @@
function on(event, emitter, callback) {
var listeners = emitter.listeners(event),
length = listeners.length;
indexOf = listeners.indexOf(callback);
if (length <= 1)
if (!~indexOf)
emitter.once(event, callback);
}