summaryrefslogtreecommitdiff
path: root/extensions/web/06_streams.js
diff options
context:
space:
mode:
authorLuca Casonato <hello@lcas.dev>2021-06-16 02:46:08 +0200
committerGitHub <noreply@github.com>2021-06-16 02:46:08 +0200
commitac431ca0763bbbde9ab60de945c9966ed61d9880 (patch)
treebdc6cbc5089cbce1ad4e516465f6ab0dd92f5e8e /extensions/web/06_streams.js
parentd7ce3adc8b97ebca61c1f527ea0f9b842d0a2dbe (diff)
fix: closing / aborting WritableStream is racy (#10982)
Diffstat (limited to 'extensions/web/06_streams.js')
-rw-r--r--extensions/web/06_streams.js6
1 files changed, 3 insertions, 3 deletions
diff --git a/extensions/web/06_streams.js b/extensions/web/06_streams.js
index b24ab21a0..be5eca6ba 100644
--- a/extensions/web/06_streams.js
+++ b/extensions/web/06_streams.js
@@ -2808,7 +2808,7 @@
function writableStreamHasOperationMarkedInFlight(stream) {
if (
stream[_inFlightWriteRequest] === undefined &&
- stream[_controller][_inFlightCloseRequest] === undefined
+ stream[_inFlightCloseRequest] === undefined
) {
return false;
}
@@ -2857,11 +2857,11 @@
assert(stream[_storedError] === undefined);
assert(stream[_state] === "writable");
const controller = stream[_controller];
- assert(controller);
+ assert(controller !== undefined);
stream[_state] = "erroring";
stream[_storedError] = reason;
const writer = stream[_writer];
- if (writer) {
+ if (writer !== undefined) {
writableStreamDefaultWriterEnsureReadyPromiseRejected(writer, reason);
}
if (