rename iterator to asyncIterator

Author: yaacovCR

src/execution/execute.ts

@@ -1055,7 +1055,7 @@ async function completeAsyncIteratorValue(
   fieldGroup: FieldGroup,
   info: GraphQLResolveInfo,
   path: Path,
-  iterator: AsyncIterator<unknown>,
+  asyncIterator: AsyncIterator<unknown>,
   incrementalDataRecord: IncrementalDataRecord | undefined,
 ): Promise<ReadonlyArray<unknown>> {
   const stream = getStreamValues(exeContext, fieldGroup, path);
@@ -1072,7 +1072,7 @@ async function completeAsyncIteratorValue(
       // eslint-disable-next-line @typescript-eslint/no-floating-promises
       executeStreamAsyncIterator(
         index,
-        iterator,
+        asyncIterator,
         exeContext,
         fieldGroup,
         info,
@@ -1088,7 +1088,7 @@ async function completeAsyncIteratorValue(
     let iteration;
     try {
       // eslint-disable-next-line no-await-in-loop
-      iteration = await iterator.next();
+      iteration = await asyncIterator.next();
       if (iteration.done) {
         break;
       }
@@ -1140,15 +1140,15 @@ function completeListValue(
   const itemType = returnType.ofType;
 
   if (isAsyncIterable(result)) {
-    const iterator = result[Symbol.asyncIterator]();
+    const asyncIterator = result[Symbol.asyncIterator]();
 
     return completeAsyncIteratorValue(
       exeContext,
       itemType,
       fieldGroup,
       info,
       path,
-      iterator,
+      asyncIterator,
       incrementalDataRecord,
     );
   }
@@ -1948,7 +1948,7 @@ function executeStreamField(
 }
 
 async function executeStreamAsyncIteratorItem(
-  iterator: AsyncIterator<unknown>,
+  asyncIterator: AsyncIterator<unknown>,
   exeContext: ExecutionContext,
   fieldGroup: FieldGroup,
   info: GraphQLResolveInfo,
@@ -1958,7 +1958,7 @@ async function executeStreamAsyncIteratorItem(
 ): Promise<IteratorResult<unknown>> {
   let item;
   try {
-    const { value, done } = await iterator.next();
+    const { value, done } = await asyncIterator.next();
     if (done) {
       incrementalDataRecord.setIsCompletedIterator();
       return { done, value: undefined };
@@ -1973,7 +1973,7 @@ async function executeStreamAsyncIteratorItem(
       itemPath,
       incrementalDataRecord,
     );
-    // don't continue if iterator throws
+    // don't continue if async iterator throws
     return { done: true, value: null };
   }
   let completedItem;
@@ -2019,7 +2019,7 @@ async function executeStreamAsyncIteratorItem(
 
 async function executeStreamAsyncIterator(
   initialIndex: number,
-  iterator: AsyncIterator<unknown>,
+  asyncIterator: AsyncIterator<unknown>,
   exeContext: ExecutionContext,
   fieldGroup: FieldGroup,
   info: GraphQLResolveInfo,
@@ -2037,15 +2037,15 @@ async function executeStreamAsyncIterator(
       label,
       path: itemPath,
       parentContext: previousIncrementalDataRecord,
-      iterator,
+      asyncIterator,
       exeContext,
     });
 
     let iteration;
     try {
       // eslint-disable-next-line no-await-in-loop
       iteration = await executeStreamAsyncIteratorItem(
-        iterator,
+        asyncIterator,
         exeContext,
         fieldGroup,
         info,
@@ -2058,8 +2058,8 @@ async function executeStreamAsyncIterator(
       filterSubsequentPayloads(exeContext, path, incrementalDataRecord);
       incrementalDataRecord.addItems(null);
       // entire stream has errored and bubbled upwards
-      if (iterator?.return) {
-        iterator.return().catch(() => {
+      if (asyncIterator?.return) {
+        asyncIterator.return().catch(() => {
           // ignore errors
         });
       }
@@ -2112,9 +2112,9 @@ function filterSubsequentPayloads(
     // incrementalDataRecord path points to nulled error field
     if (
       isStreamItemsRecord(incrementalDataRecord) &&
-      incrementalDataRecord.iterator?.return
+      incrementalDataRecord.asyncIterator?.return
     ) {
-      incrementalDataRecord.iterator.return().catch(() => {
+      incrementalDataRecord.asyncIterator.return().catch(() => {
         // ignore error
       });
     }
@@ -2199,9 +2199,9 @@ function yieldSubsequentPayloads(
     exeContext.subsequentResults.forEach((incrementalDataRecord) => {
       if (
         isStreamItemsRecord(incrementalDataRecord) &&
-        incrementalDataRecord.iterator?.return
+        incrementalDataRecord.asyncIterator?.return
       ) {
-        promises.push(incrementalDataRecord.iterator.return());
+        promises.push(incrementalDataRecord.asyncIterator.return());
       }
     });
     return Promise.all(promises);
@@ -2283,15 +2283,15 @@ class StreamItemsRecord {
   items: Array<unknown> | null;
   promise: Promise<void>;
   parentContext: IncrementalDataRecord | undefined;
-  iterator: AsyncIterator<unknown> | undefined;
+  asyncIterator: AsyncIterator<unknown> | undefined;
   isCompletedIterator?: boolean;
   isCompleted: boolean;
   _exeContext: ExecutionContext;
   _resolve?: (arg: PromiseOrValue<Array<unknown> | null>) => void;
   constructor(opts: {
     label: string | undefined;
     path: Path | undefined;
-    iterator?: AsyncIterator<unknown>;
+    asyncIterator?: AsyncIterator<unknown>;
     parentContext: IncrementalDataRecord | undefined;
     exeContext: ExecutionContext;
   }) {
@@ -2300,7 +2300,7 @@ class StreamItemsRecord {
     this.label = opts.label;
     this.path = pathToArray(opts.path);
     this.parentContext = opts.parentContext;
-    this.iterator = opts.iterator;
+    this.asyncIterator = opts.asyncIterator;
     this.errors = [];
     this._exeContext = opts.exeContext;
     this._exeContext.subsequentResults.add(this);