polish

Author: yaacovCR

src/execution/execute.ts

@@ -2041,7 +2041,7 @@ async function executeStreamIterator(
 
       if (done) {
         asyncPayloadRecord.setIsCompletedIterator();
-        asyncPayloadRecord.addItems([item]);
+        asyncPayloadRecord.addItems(null);
         break;
       }
 
@@ -2066,23 +2066,22 @@ async function executeStreamIterator(
         filterSubsequentPayloads(exeContext, itemPath, asyncPayloadRecord);
       }
 
-      let completedItems: PromiseOrValue<Array<unknown> | null>;
       if (isPromise(completedItem)) {
-        completedItems = completedItemsFromPromisedCompletedStreamedItem(
-          iterator,
-          exeContext,
-          itemType,
-          fieldNodes,
-          path,
-          itemPath,
-          completedItem,
-          asyncPayloadRecord,
+        asyncPayloadRecord.addItems(
+          completedItemsFromPromisedCompletedStreamedItem(
+            iterator,
+            exeContext,
+            itemType,
+            fieldNodes,
+            path,
+            itemPath,
+            completedItem,
+            asyncPayloadRecord,
+          ),
         );
       } else {
-        completedItems = [completedItem];
+        asyncPayloadRecord.addItems([completedItem]);
       }
-
-      asyncPayloadRecord.addItems(completedItems);
     } catch (error) {
       handleStreamError(iterator, exeContext, path, asyncPayloadRecord, error);
       asyncPayloadRecord.addItems(null);