nodejs
diff --git a/‎lib/internal/streams/iter/broadcast.js‎
Lines changed: 1 addition & 0 deletions b/‎lib/internal/streams/iter/broadcast.js‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎test/parallel/test-stream-iter-broadcast-basic.js‎
Lines changed: 13 additions & 0 deletions b/‎test/parallel/test-stream-iter-broadcast-basic.js‎
Lines changed: 13 additions & 0 deletions
@@ -165,6 +165,7 @@ class BroadcastImpl {
 
     function detach() {
       state.detached = true;
+      state.resolve?.({ __proto__: null, done: true, value: undefined });
       state.resolve = null;
       state.reject = null;
       if (self.#deleteConsumer(state)) {
 
@@ -161,6 +161,18 @@ async function testCancelWithReason() {
   assert.strictEqual(result.message, 'cancelled');
 }
 
+async function testPendingNextSettlesAfterReturn() {
+  const { broadcast: bc } = broadcast();
+  const iter = bc.push()[Symbol.asyncIterator]();
+
+  const pendingNext = iter.next();
+  await iter.return();
+
+  const result = await pendingNext;
+  assert.strictEqual(result.done, true);
+  assert.strictEqual(result.value, undefined);
+}
+
 // =============================================================================
 // Writer fail detaches consumers
 // =============================================================================
@@ -254,6 +266,7 @@ Promise.all([
   testCancelWithoutReason(),
   testCancelWithReason(),
   testCancelWithFalsyReason(),
+  testPendingNextSettlesAfterReturn(),
   testFailDetachesConsumers(),
   testWriterFailIdempotent(),
   testLateJoinerSeesBufferedData(),