introduce completeMaybePromisedListItemValue

Author: yaacovCR

src/execution/execute.ts

@@ -1273,43 +1273,20 @@ async function completeAsyncIteratorValue(
       }
 
       const item = iteration.value;
-      // TODO: add tests for stream backed by asyncIterator that returns a promise
-      /* c8 ignore start */
-      if (isPromise(item)) {
-        completedResults.push(
-          completePromisedListItemValue(
-            item,
-            graphqlWrappedResult,
-            exeContext,
-            itemType,
-            fieldDetailsList,
-            info,
-            itemPath,
-            incrementalContext,
-            deferMap,
-          ),
-        );
-        containsPromise = true;
-      } else if (
-        /* c8 ignore stop */
-        completeListItemValue(
-          item,
-          completedResults,
-          graphqlWrappedResult,
-          exeContext,
-          itemType,
-          fieldDetailsList,
-          info,
-          itemPath,
-          incrementalContext,
-          deferMap,
-        )
-        // TODO: add tests for stream backed by asyncIterator that completes to a promise
-        /* c8 ignore start */
-      ) {
-        containsPromise = true;
-      }
-      /* c8 ignore stop */
+
+      containsPromise = completeMaybePromisedListItemValue(
+        item,
+        completedResults,
+        graphqlWrappedResult,
+        exeContext,
+        itemType,
+        fieldDetailsList,
+        info,
+        itemPath,
+        incrementalContext,
+        deferMap,
+      );
+
       index++;
     }
   } catch (error) {
@@ -1432,37 +1409,19 @@ function completeIterableValue(
     // since from here on it is not ever accessed by resolver functions.
     const itemPath = addPath(path, index, undefined);
 
-    if (isPromise(item)) {
-      completedResults.push(
-        completePromisedListItemValue(
-          item,
-          graphqlWrappedResult,
-          exeContext,
-          itemType,
-          fieldDetailsList,
-          info,
-          itemPath,
-          incrementalContext,
-          deferMap,
-        ),
-      );
-      containsPromise = true;
-    } else if (
-      completeListItemValue(
-        item,
-        completedResults,
-        graphqlWrappedResult,
-        exeContext,
-        itemType,
-        fieldDetailsList,
-        info,
-        itemPath,
-        incrementalContext,
-        deferMap,
-      )
-    ) {
-      containsPromise = true;
-    }
+    containsPromise = completeMaybePromisedListItemValue(
+      item,
+      completedResults,
+      graphqlWrappedResult,
+      exeContext,
+      itemType,
+      fieldDetailsList,
+      info,
+      itemPath,
+      incrementalContext,
+      deferMap,
+    );
+
     index++;
 
     iteration = iterator.next();
@@ -1481,6 +1440,48 @@ function completeIterableValue(
  *
  * Returns true if the value is a Promise.
  */
+function completeMaybePromisedListItemValue(
+  item: unknown,
+  completedResults: Array<unknown>,
+  parent: GraphQLWrappedResult<Array<unknown>>,
+  exeContext: ExecutionContext,
+  itemType: GraphQLOutputType,
+  fieldDetailsList: FieldDetailsList,
+  info: GraphQLResolveInfo,
+  itemPath: Path,
+  incrementalContext: IncrementalContext | undefined,
+  deferMap: ReadonlyMap<DeferUsage, DeferredFragmentRecord> | undefined,
+): boolean {
+  if (isPromise(item)) {
+    completedResults.push(
+      completePromisedListItemValue(
+        item,
+        parent,
+        exeContext,
+        itemType,
+        fieldDetailsList,
+        info,
+        itemPath,
+        incrementalContext,
+        deferMap,
+      ),
+    );
+    return true;
+  }
+  return completeListItemValue(
+    item,
+    completedResults,
+    parent,
+    exeContext,
+    itemType,
+    fieldDetailsList,
+    info,
+    itemPath,
+    incrementalContext,
+    deferMap,
+  );
+}
+
 function completeListItemValue(
   item: unknown,
   completedResults: Array<unknown>,