From aea9ad99e3c75c583df8f8397ae0d9de80f921a2 Mon Sep 17 00:00:00 2001 From: coderaiser Date: Fri, 30 May 2014 02:17:05 -0400 Subject: [PATCH] fix(pipe) on: length -> indexOf --- lib/server/pipe.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/server/pipe.js b/lib/server/pipe.js index 0e7a4c06..e86e65ba 100644 --- a/lib/server/pipe.js +++ b/lib/server/pipe.js @@ -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); }