stream: update ongoing promise in async iterator return() method

nodejs · Apr 23, 2024 · d7436b4 · d7436b4
1 parent 231548b
commit d7436b4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/internal/webstreams/readablestream.js b/lib/internal/webstreams/readablestream.js
@@ -545,12 +545,14 @@ class ReadableStream {
       },
 
       return(error) {
-        return state.current ?
+        started = true;
+        state.current = state.current !== undefined ?
           PromisePrototypeThen(
             state.current,
             () => returnSteps(error),
             () => returnSteps(error)) :
           returnSteps(error);
+        return state.current;
       },
 
       [SymbolAsyncIterator]() { return this; },