Lines Matching refs:emitter
406 * Increases the max listeners of the event emitter.
425 * Returns the current max listener value for the event emitter.
593 `added to ${inspect(target, { depth: -1 })}. Use emitter.setMaxListeners() to increase limit`,
594 { name: 'MaxListenersExceededWarning', emitter: target, type: type, count: existing.length });
603 * Adds a listener to the event emitter.
645 * Adds a one-time `listener` function to the event emitter.
732 * Removes all listeners from the event emitter. (Only
825 * @param {EventEmitter} emitter
829 EventEmitter.listenerCount = function(emitter, type) {
830 if (typeof emitter.listenerCount === 'function') {
831 return emitter.listenerCount(type);
833 return FunctionPrototypeCall(listenerCount, emitter, type);
879 * the emitter has registered listeners.
935 throw new ERR_INVALID_ARG_TYPE('emitter',
952 throw new ERR_INVALID_ARG_TYPE('emitter',
958 * Creates a `Promise` that is fulfilled when the emitter
960 * @param {EventEmitter} emitter
965 async function once(emitter, name, options = kEmptyObject) {
972 emitter.removeListener(name, resolver);
979 if (typeof emitter.removeListener === 'function') {
980 emitter.removeListener('error', errorListener);
990 eventTargetAgnosticAddListener(emitter, name, resolver, opts);
991 if (name !== 'error' && typeof emitter.once === 'function') {
994 emitter.once('error', errorListener);
997 eventTargetAgnosticRemoveListener(emitter, name, resolver);
998 eventTargetAgnosticRemoveListener(emitter, 'error', errorListener);
1015 function eventTargetAgnosticRemoveListener(emitter, name, listener, flags) {
1016 if (typeof emitter.removeListener === 'function') {
1017 emitter.removeListener(name, listener);
1018 } else if (typeof emitter.removeEventListener === 'function') {
1019 emitter.removeEventListener(name, listener, flags);
1021 throw new ERR_INVALID_ARG_TYPE('emitter', 'EventEmitter', emitter);
1025 function eventTargetAgnosticAddListener(emitter, name, listener, flags) {
1026 if (typeof emitter.on === 'function') {
1028 emitter.once(name, listener);
1030 emitter.on(name, listener);
1032 } else if (typeof emitter.addEventListener === 'function') {
1033 emitter.addEventListener(name, listener, flags);
1035 throw new ERR_INVALID_ARG_TYPE('emitter', 'EventEmitter', emitter);
1041 * @param {EventEmitter} emitter
1046 function on(emitter, event, options = kEmptyObject) {
1087 eventTargetAgnosticRemoveListener(emitter, event, eventHandler);
1088 eventTargetAgnosticRemoveListener(emitter, 'error', errorHandler);
1113 eventTargetAgnosticRemoveListener(emitter, event, eventHandler);
1114 eventTargetAgnosticRemoveListener(emitter, 'error', errorHandler);
1122 eventTargetAgnosticAddListener(emitter, event, eventHandler);
1123 if (event !== 'error' && typeof emitter.on === 'function') {
1124 emitter.on('error', errorHandler);