Skip to content

Commit 6d1bbf7

Browse files
committed
fixup
1 parent f8e42d2 commit 6d1bbf7

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

lib/internal/streams/transform.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,9 @@ Transform.prototype._write = function(chunk, encoding, callback) {
228228
}
229229
},
230230
(err) => {
231-
process.nextTick(callback, err);
231+
if (!called) {
232+
process.nextTick(callback, err);
233+
}
232234
});
233235
}
234236
} catch (err) {

0 commit comments

Comments
 (0)