Skip to content

Commit 0acc48e

Browse files
committed
fixup
1 parent dbf901c commit 0acc48e

File tree

1 file changed

+1
-16
lines changed

1 file changed

+1
-16
lines changed

lib/internal/streams/readable.js

Lines changed: 1 addition & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -485,22 +485,7 @@ Readable.prototype.read = function(n) {
485485
state.needReadable = true;
486486

487487
// Call internal read method
488-
try {
489-
const result = this._read(state.highWaterMark);
490-
if (result != null) {
491-
const then = result.then;
492-
if (typeof then === 'function') {
493-
then.call(
494-
result,
495-
nop,
496-
function(err) {
497-
errorOrDestroy(this, err);
498-
});
499-
}
500-
}
501-
} catch (err) {
502-
errorOrDestroy(this, err);
503-
}
488+
this._read(state.highWaterMark);
504489

505490
state.sync = false;
506491
// If _read pushed data synchronously, then `reading` will be false,

0 commit comments

Comments
 (0)