Execute each of the listeners in order with the supplied arguments.
+
+### Class Method: EventEmitter.listenerCount(emitter, event)
+
+Return the number of listeners for a given event.
+
+
### Event: 'newListener'
* `event` {String} The event name
module.exports = Readable;
Readable.ReadableState = ReadableState;
+var EE = require('events').EventEmitter;
var Stream = require('stream');
var util = require('util');
var StringDecoder;
// however, don't suppress the throwing behavior for this.
function onerror(er) {
unpipe();
- if (dest.listeners('error').length === 0)
+ if (EE.listenerCount(dest, 'error') === 0)
dest.emit('error', er);
}
dest.once('error', onerror);
state.flowing = false;
// if there were data event listeners added, then switch to old mode.
- if (src.listeners('data').length)
+ if (EE.listenerCount(src, 'data') > 0)
emitDataEvents(src);
return;
}
}
return this._events[type].slice(0);
};
+
+EventEmitter.listenerCount = function(emitter, type) {
+ var ret;
+ if (!emitter._events || !emitter._events[type])
+ ret = 0;
+ else if (typeof emitter._events[type] === 'function')
+ ret = 1;
+ else
+ ret = emitter._events[type].length;
+ return ret;
+};
stat.removeAllListeners('change');
}
- if (stat.listeners('change').length === 0) {
+ if (EventEmitter.listenerCount(stat, 'change') === 0) {
stat.stop();
statWatchers[filename] = undefined;
}
var bodyHead = d.slice(start + bytesParsed, end);
var eventName = req.method === 'CONNECT' ? 'connect' : 'upgrade';
- if (req.listeners(eventName).length) {
+ if (EventEmitter.listenerCount(req, eventName) > 0) {
req.upgradeOrConnect = true;
// detach the socket
var bodyHead = d.slice(start + bytesParsed, end);
var eventName = req.method === 'CONNECT' ? 'connect' : 'upgrade';
- if (self.listeners(eventName).length) {
+ if (EventEmitter.listenerCount(self, eventName) > 0) {
self.emit(eventName, req, req.socket, bodyHead);
} else {
// Got upgrade header or CONNECT method, but have no handler.
(req.httpVersionMajor == 1 && req.httpVersionMinor == 1) &&
continueExpression.test(req.headers['expect'])) {
res._expect_continue = true;
- if (self.listeners('checkContinue').length) {
+ if (EventEmitter.listenerCount(self, 'checkContinue') > 0) {
self.emit('checkContinue', req, res);
} else {
res.writeContinue();
switch (key.name) {
case 'c':
- if (this.listeners('SIGINT').length) {
+ if (EventEmitter.listenerCount(this, 'SIGINT') > 0) {
this.emit('SIGINT');
} else {
// This readline instance is finished
case 'z':
if (process.platform == 'win32') break;
- if (this.listeners('SIGTSTP').length) {
+ if (EventEmitter.listenerCount(this, 'SIGTSTP') > 0) {
this.emit('SIGTSTP');
} else {
process.once('SIGCONT', (function(self) {
stream._keypressDecoder = new StringDecoder('utf8');
function onData(b) {
- if (stream.listeners('keypress').length > 0) {
+ if (EventEmitter.listenerCount(stream, 'keypress') > 0) {
var r = stream._keypressDecoder.write(b);
if (r) emitKey(stream, r);
} else {
}
}
- if (stream.listeners('keypress').length > 0) {
+ if (EventEmitter.listenerCount(stream, 'keypress') > 0) {
stream.on('data', onData);
} else {
stream.on('newListener', onNewListener);
module.exports = Stream;
-var events = require('events');
+var EE = require('events').EventEmitter;
var util = require('util');
-util.inherits(Stream, events.EventEmitter);
+util.inherits(Stream, EE);
Stream.Readable = require('_stream_readable');
Stream.Writable = require('_stream_writable');
Stream.Duplex = require('_stream_duplex');
// part of this class) is overridden in the Readable class.
function Stream() {
- events.EventEmitter.call(this);
+ EE.call(this);
}
Stream.prototype.pipe = function(dest, options) {
// don't leave dangling pipes when there are errors.
function onerror(er) {
cleanup();
- if (this.listeners('error').length === 0) {
+ if (EE.listenerCount(this, 'error') === 0) {
throw er; // Unhandled stream error in pipe.
}
}