nodejs
diff --git a/‎lib/_http_server.js‎
Lines changed: 2 additions & 2 deletions b/‎lib/_http_server.js‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎lib/_stream_readable.js‎
Lines changed: 2 additions & 2 deletions b/‎lib/_stream_readable.js‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎lib/events.js‎
Lines changed: 7 additions & 2 deletions b/‎lib/events.js‎
Lines changed: 7 additions & 2 deletions
diff --git a/‎lib/stream.js‎
Lines changed: 1 addition & 1 deletion b/‎lib/stream.js‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎test/parallel/test-stream-pipe-without-listenerCount.js‎
Lines changed: 19 additions & 0 deletions b/‎test/parallel/test-stream-pipe-without-listenerCount.js‎
Lines changed: 19 additions & 0 deletions
@@ -374,7 +374,7 @@ function connectionListener(socket) {
       parser = null;
 
       var eventName = req.method === 'CONNECT' ? 'connect' : 'upgrade';
-      if (self.listenerCount(eventName) > 0) {
+      if (EventEmitter.listenerCount(self, eventName) > 0) {
         debug('SERVER have listener for %s', eventName);
         var bodyHead = d.slice(bytesParsed, d.length);
 
@@ -497,7 +497,7 @@ function connectionListener(socket) {
         (req.httpVersionMajor == 1 && req.httpVersionMinor == 1) &&
         continueExpression.test(req.headers['expect'])) {
       res._expect_continue = true;
-      if (self.listenerCount('checkContinue') > 0) {
+      if (EventEmitter.listenerCount(self, 'checkContinue') > 0) {
         self.emit('checkContinue', req, res);
       } else {
         res.writeContinue();
 
@@ -537,7 +537,7 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
     debug('onerror', er);
     unpipe();
     dest.removeListener('error', onerror);
-    if (dest.listenerCount('error') === 0)
+    if (EE.listenerCount(dest, 'error') === 0)
       dest.emit('error', er);
   }
   // This is a brutally ugly hack to make sure that our error handler
@@ -586,7 +586,7 @@ function pipeOnDrain(src) {
     debug('pipeOnDrain', state.awaitDrain);
     if (state.awaitDrain)
       state.awaitDrain--;
-    if (state.awaitDrain === 0 && src.listenerCount('data')) {
+    if (state.awaitDrain === 0 && EE.listenerCount(src, 'data')) {
       state.flowing = true;
       flow(src);
     }
 
@@ -395,10 +395,15 @@ EventEmitter.prototype.listeners = function listeners(type) {
 };
 
 EventEmitter.listenerCount = function(emitter, type) {
-  return emitter.listenerCount(type);
+  if (typeof emitter.listenerCount === 'function') {
+    return emitter.listenerCount(type);
+  } else {
+    return listenerCount.call(emitter, type);
+  }
 };
 
-EventEmitter.prototype.listenerCount = function listenerCount(type) {
+EventEmitter.prototype.listenerCount = listenerCount;
+function listenerCount(type) {
   const events = this._events;
 
   if (events) {
 
@@ -70,7 +70,7 @@ Stream.prototype.pipe = function(dest, options) {
   // don't leave dangling pipes when there are errors.
   function onerror(er) {
     cleanup();
-    if (this.listenerCount('error') === 0) {
+    if (EE.listenerCount(this, 'error') === 0) {
       throw er; // Unhandled stream error in pipe.
     }
   }
 
@@ -0,0 +1,19 @@
+'use strict';
+const common = require('../common');
+const stream = require('stream');
+
+const r = new stream.Stream();
+r.listenerCount = undefined;
+
+const w = new stream.Stream();
+w.listenerCount = undefined;
+
+w.on('pipe', function() {
+  r.emit('error', new Error('Readable Error'));
+  w.emit('error', new Error('Writable Error'));
+});
+r.on('error', common.mustCall(noop));
+w.on('error', common.mustCall(noop));
+r.pipe(w);
+
+function noop() {};
Original file line number	Diff line number	Diff line change
@@ -70,7 +70,7 @@ Stream.prototype.pipe = function(dest, options) {
70	70	// don't leave dangling pipes when there are errors.
71	71	function onerror(er) {
72	72	cleanup();
73		- if (this.listenerCount('error') === 0) {
	73	+ if (EE.listenerCount(this, 'error') === 0) {
74	74	throw er; // Unhandled stream error in pipe.
75	75	}
76	76	}