aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/streams.exports.js
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-15 00:13:09 -0800
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-15 00:13:09 -0800
commitc7e3b4aaa6d0ffdcaca3cadd79fe9ef3d96d3ef6 (patch)
tree95c18a00a89ac0df66bccd9e0559d9eb7205fb08 /src/bun.js/streams.exports.js
parent44babb9ce5a4e26fc43b002dedbf194c31331a0e (diff)
downloadbun-jarred/dump.tar.gz
bun-jarred/dump.tar.zst
bun-jarred/dump.zip
Diffstat (limited to '')
-rw-r--r--src/bun.js/streams.exports.js3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/bun.js/streams.exports.js b/src/bun.js/streams.exports.js
index 4e812437e..c6c2a5a00 100644
--- a/src/bun.js/streams.exports.js
+++ b/src/bun.js/streams.exports.js
@@ -2039,7 +2039,7 @@ var require_destroy = __commonJS({
r.destroyed = true;
}
if (!s.constructed) {
- this.once(kDestroy, function (er) {
+ this.once(kDestroy, (er) => {
_destroy(this, aggregateTwoErrors(er, err), cb);
});
} else {
@@ -5825,6 +5825,7 @@ function createNativeStream(nativeType, Readable) {
}
_construct(cb) {
+ // TODO: why do we need to set this flag here?
this._readableState.constructed = true;
cb();
}