diff options
author | Trevor Norris <trev.norris@gmail.com> | 2013-02-14 00:48:11 -0800 |
---|---|---|
committer | isaacs <i@izs.me> | 2013-03-01 17:36:47 -0800 |
commit | 75305f3babd9e927e92b0d9b70d8bb026492ebd0 (patch) | |
tree | ad953b7593675e5241f47810b83cafaab28fe576 /lib/stream.js | |
parent | 7707acd6efd40b15f9ee1190d75176d9d3639c0e (diff) | |
download | android-node-v8-75305f3babd9e927e92b0d9b70d8bb026492ebd0.tar.gz android-node-v8-75305f3babd9e927e92b0d9b70d8bb026492ebd0.tar.bz2 android-node-v8-75305f3babd9e927e92b0d9b70d8bb026492ebd0.zip |
events: add check for listeners length
Ability to return just the length of listeners for a given type, using
EventEmitter.listenerCount(emitter, event). This will be a lot cheaper
than creating a copy of the listeners array just to check its length.
Diffstat (limited to 'lib/stream.js')
-rw-r--r-- | lib/stream.js | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/stream.js b/lib/stream.js index 481d7644e5..098ff613d2 100644 --- a/lib/stream.js +++ b/lib/stream.js @@ -21,10 +21,10 @@ 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'); @@ -40,7 +40,7 @@ Stream.Stream = Stream; // 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) { @@ -90,7 +90,7 @@ 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. } } |