We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 02c407c commit 3da7ea0Copy full SHA for 3da7ea0
lib/internal/streams/readable.js
@@ -764,7 +764,7 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
764
debug('onerror', er);
765
unpipe();
766
dest.removeListener('error', onerror);
767
- if (EE.listenerCount(dest, 'error') === 0) {
+ if (dest.listenerCount('error') === 0) {
768
const s = dest._writableState || dest._readableState;
769
if (s && !s.errorEmitted) {
770
// User incorrectly emitted 'error' directly on the stream.
@@ -829,7 +829,7 @@ function pipeOnDrain(src, dest) {
829
}
830
831
if ((!state.awaitDrainWriters || state.awaitDrainWriters.size === 0) &&
832
- EE.listenerCount(src, 'data')) {
+ src.listenerCount('data')) {
833
src.resume();
834
835
};
0 commit comments