DRY up listenerCount check

Author: phated

lib/sink.js

@@ -6,6 +6,10 @@ function listenerCount(stream, evt) {
   return stream.listeners(evt).length;
 }
 
+function hasListeners(stream) {
+  return !!(listenerCount(stream, 'readable') || listenerCount(stream, 'data'));
+}
+
 function sink(stream) {
   var sinkStream = new Writable({
     objectMode: true,
@@ -19,7 +23,7 @@ function sink(stream) {
       return;
     }
 
-    if (listenerCount(stream, 'readable') || listenerCount(stream, 'data')) {
+    if (hasListeners(stream)) {
       stream.unpipe(sinkStream);
     }
   }
@@ -28,7 +32,7 @@ function sink(stream) {
   stream.on('removeListener', removeSink);
 
   return function() {
-    if (listenerCount(stream, 'readable') || listenerCount(stream, 'data')) {
+    if (hasListeners(stream)) {
       return;
     }