WIP fix flush issue

oven-sh · Sep 17, 2024 · 95ec0d9 · 95ec0d9
1 parent 3d68a94
commit 95ec0d9
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/src/js/builtins/ReadableStreamInternals.ts b/src/js/builtins/ReadableStreamInternals.ts
@@ -1101,15 +1101,8 @@ export function onFlushDirectStream() {
   }
 
   var _pendingRead = this._pendingRead;
-  this._pendingRead = undefined;
   if (_pendingRead && $isPromise(_pendingRead)) {
-    var flushed = this.$sink.flush();
-    if (flushed?.byteLength) {
-      this._pendingRead = $getByIdDirectPrivate(stream, "readRequests")?.shift();
-      $fulfillPromise(_pendingRead, { value: flushed, done: false });
-    } else {
-      this._pendingRead = _pendingRead;
-    }
+    this.$sink.flush();
   } else if ($getByIdDirectPrivate(stream, "readRequests")?.isNotEmpty()) {
     var flushed = this.$sink.flush();
     if (flushed?.byteLength) {