WIP fix flush issue

2026-02-02 23:18:47 +00:00 · 2024-12-06 14:53:23 -08:00
1 changed files with 1 additions and 8 deletions
--- a/src/js/builtins/ReadableStreamInternals.ts
+++ b/src/js/builtins/ReadableStreamInternals.ts
@@ -1104,15 +1104,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) {