Skip to content

Commit c01a0b9

Browse files
committed
stream: catch and forward error from dest.write
1 parent e2242b4 commit c01a0b9

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

lib/internal/streams/readable.js

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1004,10 +1004,15 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
10041004
src.on('data', ondata);
10051005
function ondata(chunk) {
10061006
debug('ondata');
1007-
const ret = dest.write(chunk);
1008-
debug('dest.write', ret);
1009-
if (ret === false) {
1010-
pause();
1007+
try {
1008+
const ret = dest.write(chunk);
1009+
debug('dest.write', ret);
1010+
1011+
if (ret === false) {
1012+
pause();
1013+
}
1014+
} catch (error) {
1015+
dest.destroy(error);
10111016
}
10121017
}
10131018

0 commit comments

Comments
 (0)