fix: clean up observableToAsyncIterable state when observable completes

.changeset/@ardatan_relay-compiler-8057-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@ardatan/relay-compiler": patch
+---
+dependencies updates:
+  - Updated dependency [`@babel/runtime@^7.29.2` ↗︎](https://www.npmjs.com/package/@babel/runtime/v/7.29.2) (from `^7.26.10`, in `dependencies`)

.changeset/@graphql-tools_graphql-tag-pluck-8057-dependencies.md

@@ -0,0 +1,5 @@
+---
+"@graphql-tools/graphql-tag-pluck": patch
+---
+dependencies updates:
+  - Updated dependency [`@babel/parser@^7.29.2` ↗︎](https://www.npmjs.com/package/@babel/parser/v/7.29.2) (from `^7.26.10`, in `dependencies`)

packages/utils/src/observableToAsyncIterable.ts

@@ -42,6 +42,8 @@ export function observableToAsyncIterable<T>(observable: Observable<T>): AsyncIt
     if (pullQueue.length !== 0) {
       // It is safe to use the ! operator here as we check the length.
       pullQueue.shift()!({ done: true });
+      // Clean up remaining state after signaling done to the pending consumer.
+      emptyQueue();
     } else {
       pushQueue.push({ done: true });
     }
@@ -52,6 +54,10 @@ export function observableToAsyncIterable<T>(observable: Observable<T>): AsyncIt
       if (pushQueue.length !== 0) {
         const element = pushQueue.shift();
         // either {value: {errors: [...]}} or {value: ...}
+        if (element.done) {
+          // Clean up references before delivering the done signal.
+          emptyQueue();
+        }
         resolve(element);
       } else {
         pullQueue.push(resolve);