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

nodejs · Apr 23, 2024 · 91bb2eb · 91bb2eb
1 parent 231548b
commit 91bb2eb
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; },