events: add listener argument to listenerCount

PR-URL: #46523
Reviewed-By: Robert Nagy <ronagy@icloud.com>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Moshe Atlow <moshe@atlow.co.il>

Author: ShogunPanda

doc/api/deprecations.md

@@ -3364,7 +3364,7 @@ In a future version of Node.js, [`message.headers`][],
 [`dnsPromises.lookup()`]: dns.md#dnspromiseslookuphostname-options
 [`domain`]: domain.md
 [`ecdh.setPublicKey()`]: crypto.md#ecdhsetpublickeypublickey-encoding
-[`emitter.listenerCount(eventName)`]: events.md#emitterlistenercounteventname
+[`emitter.listenerCount(eventName)`]: events.md#emitterlistenercounteventname-listener
 [`events.listenerCount(emitter, eventName)`]: events.md#eventslistenercountemitter-eventname
 [`fs.FileHandle`]: fs.md#class-filehandle
 [`fs.access()`]: fs.md#fsaccesspath-mode-callback

doc/api/events.md

@@ -646,16 +646,23 @@ Returns the current max listener value for the `EventEmitter` which is either
 set by [`emitter.setMaxListeners(n)`][] or defaults to
 [`events.defaultMaxListeners`][].
 
-### `emitter.listenerCount(eventName)`
+### `emitter.listenerCount(eventName[, listener])`
 
 <!-- YAML
 added: v3.2.0
+changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/46523
+ description: Added the `listener` argument.
 -->
 
 *`eventName` {string|symbol} The name of the event being listened for
+*`listener` {Function} The event handler function
 * Returns: {integer}
 
-Returns the number of listeners listening to the event named `eventName`.
+Returns the number of listeners listening for the event named `eventName`.
+If `listener` is provided, it will return how many times the listener is found
+in the list of the listeners of the event.
 
 ### `emitter.listeners(eventName)`
 
@@ -2462,7 +2469,7 @@ to the `EventTarget`.
 [`EventTarget` error handling]: #eventtarget-error-handling
 [`Event` Web API]: https://dom.spec.whatwg.org/#event
 [`domain`]: domain.md
-[`emitter.listenerCount()`]: #emitterlistenercounteventname
+[`emitter.listenerCount()`]: #emitterlistenercounteventname-listener
 [`emitter.removeListener()`]: #emitterremovelistenereventname-listener
 [`emitter.setMaxListeners(n)`]: #emittersetmaxlistenersn
 [`event.defaultPrevented`]: #eventdefaultprevented

lib/events.js

@@ -835,17 +835,34 @@ EventEmitter.prototype.listenerCount = listenerCount;
  * Returns the number of listeners listening to event name
  * specified as `type`.
  * @param {string | symbol} type
+ * @param {Function} listener
  * @returns {number}
  */
-functionlistenerCount(type){
+functionlistenerCount(type,listener){
 constevents=this._events;
 
 if(events!==undefined){
 constevlistener=events[type];
 
 if(typeofevlistener==='function'){
+if(listener!=null){
+returnlistener===evlistener ? 1 : 0;
+}
+
 return1;
 }elseif(evlistener!==undefined){
+if(listener!=null){
+letmatching=0;
+
+for(leti=0,l=evlistener.length;i<l;i++){
+if(evlistener[i]===listener||evlistener[i].listener===listener){
+matching++;
+}
+}
+
+returnmatching;
+}
+
 returnevlistener.length;
 }
 }

test/parallel/test-events-listener-count-with-listener.js

@@ -0,0 +1,53 @@
+'use strict';
+
+constcommon=require('../common');
+constEventEmitter=require('events');
+constassert=require('assert');
+
+constEE=newEventEmitter();
+consthandler=common.mustCall(undefined,3);
+constanotherHandler=common.mustCall();
+
+assert.strictEqual(EE.listenerCount('event'),0);
+assert.strictEqual(EE.listenerCount('event',handler),0);
+assert.strictEqual(EE.listenerCount('event',anotherHandler),0);
+
+EE.on('event',handler);
+
+assert.strictEqual(EE.listenerCount('event'),1);
+assert.strictEqual(EE.listenerCount('event',handler),1);
+assert.strictEqual(EE.listenerCount('event',anotherHandler),0);
+
+EE.once('event',anotherHandler);
+
+assert.strictEqual(EE.listenerCount('event'),2);
+assert.strictEqual(EE.listenerCount('event',handler),1);
+assert.strictEqual(EE.listenerCount('event',anotherHandler),1);
+
+assert.strictEqual(EE.listenerCount('another-event'),0);
+assert.strictEqual(EE.listenerCount('another-event',handler),0);
+assert.strictEqual(EE.listenerCount('another-event',anotherHandler),0);
+
+EE.once('event',handler);
+
+assert.strictEqual(EE.listenerCount('event'),3);
+assert.strictEqual(EE.listenerCount('event',handler),2);
+assert.strictEqual(EE.listenerCount('event',anotherHandler),1);
+
+EE.emit('event');
+
+assert.strictEqual(EE.listenerCount('event'),1);
+assert.strictEqual(EE.listenerCount('event',handler),1);
+assert.strictEqual(EE.listenerCount('event',anotherHandler),0);
+
+EE.emit('event');
+
+assert.strictEqual(EE.listenerCount('event'),1);
+assert.strictEqual(EE.listenerCount('event',handler),1);
+assert.strictEqual(EE.listenerCount('event',anotherHandler),0);
+
+EE.off('event',handler);
+
+assert.strictEqual(EE.listenerCount('event'),0);
+assert.strictEqual(EE.listenerCount('event',handler),0);
+assert.strictEqual(EE.listenerCount('event',anotherHandler),0);