move function to help with overall diff

graphql · Nov 22, 2022 · 26002c8 · 26002c8
1 parent 48fe4e2
commit 26002c8
Showing 1 changed file with 22 additions and 22 deletions.
diff --git a/src/execution/execute.ts b/src/execution/execute.ts
@@ -2094,6 +2094,28 @@ async function executeStreamIterator(
   }
 }
 
+function filterSubsequentPayloads(
+  exeContext: ExecutionContext,
+  nullPath: Path,
+  currentAsyncRecord: AsyncPayloadRecord | undefined,
+): void {
+  const nullPathArray = pathToArray(nullPath);
+  exeContext.publisher.filter((asyncRecord) => {
+    if (asyncRecord === currentAsyncRecord) {
+      // don't remove payload from where error originates
+      return true;
+    }
+    for (let i = 0; i < nullPathArray.length; i++) {
+      if (asyncRecord.path[i] !== nullPathArray[i]) {
+        // asyncRecord points to a path unaffected by this payload
+        return true;
+      }
+    }
+
+    return false;
+  });
+}
+
 function toIncrementalResult(
   asyncPayloadRecord: AsyncPayloadRecord,
 ): IncrementalResult {
@@ -2123,28 +2145,6 @@ function toPayload(
   return incremental.length ? { incremental, hasNext } : { hasNext };
 }
 
-function filterSubsequentPayloads(
-  exeContext: ExecutionContext,
-  nullPath: Path,
-  currentAsyncRecord: AsyncPayloadRecord | undefined,
-): void {
-  const nullPathArray = pathToArray(nullPath);
-  exeContext.publisher.filter((asyncRecord) => {
-    if (asyncRecord === currentAsyncRecord) {
-      // don't remove payload from where error originates
-      return true;
-    }
-    for (let i = 0; i < nullPathArray.length; i++) {
-      if (asyncRecord.path[i] !== nullPathArray[i]) {
-        // asyncRecord points to a path unaffected by this payload
-        return true;
-      }
-    }
-
-    return false;
-  });
-}
-
 class DeferredFragmentRecord {
   type: 'defer';
   errors: Array<GraphQLError>;