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>,
   asyncPayloadRecord: AsyncPayloadRecord | 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,
       asyncPayloadRecord,
     );
   }
@@ -1948,7 +1948,7 @@ function executeStreamField(
 }
 
 async function executeStreamAsyncIteratorItem(
-  iterator: AsyncIterator<unknown>,
+  asyncIterator: AsyncIterator<unknown>,
   exeContext: ExecutionContext,
   fieldGroup: FieldGroup,
   info: GraphQLResolveInfo,
@@ -1958,9 +1958,9 @@ async function executeStreamAsyncIteratorItem(
 ): Promise<IteratorResult<unknown>> {
   let item;
   try {
-    const { value, done } = await iterator.next();
+    const { value, done } = await asyncIterator.next();
     if (done) {
-      asyncPayloadRecord.setIsCompletedIterator();
+      asyncPayloadRecord.setIsCompletedAsyncIterator();
       return { done, value: undefined };
     }
     item = value;
@@ -1973,7 +1973,7 @@ async function executeStreamAsyncIteratorItem(
       itemPath,
       asyncPayloadRecord,
     );
-    // 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: previousAsyncPayloadRecord,
-      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, asyncPayloadRecord);
       asyncPayloadRecord.addItems(null);
       // entire stream has errored and bubbled upwards
-      if (iterator?.return) {
-        iterator.return().catch(() => {
+      if (asyncIterator?.return) {
+        asyncIterator.return().catch(() => {
           // ignore errors
         });
       }
@@ -2110,8 +2110,8 @@ function filterSubsequentPayloads(
       }
     }
     // asyncRecord path points to nulled error field
-    if (isStreamPayload(asyncRecord) && asyncRecord.iterator?.return) {
-      asyncRecord.iterator.return().catch(() => {
+    if (isStreamPayload(asyncRecord) && asyncRecord.asyncIterator?.return) {
+      asyncRecord.asyncIterator.return().catch(() => {
         // ignore error
       });
     }
@@ -2131,7 +2131,7 @@ function getCompletedIncrementalResults(
     exeContext.subsequentPayloads.delete(asyncPayloadRecord);
     if (isStreamPayload(asyncPayloadRecord)) {
       const items = asyncPayloadRecord.items;
-      if (asyncPayloadRecord.isCompletedIterator) {
+      if (asyncPayloadRecord.isCompletedAsyncIterator) {
         // async iterable resolver just finished but there may be pending payloads
         continue;
       }
@@ -2196,9 +2196,9 @@ function yieldSubsequentPayloads(
     exeContext.subsequentPayloads.forEach((asyncPayloadRecord) => {
       if (
         isStreamPayload(asyncPayloadRecord) &&
-        asyncPayloadRecord.iterator?.return
+        asyncPayloadRecord.asyncIterator?.return
       ) {
-        promises.push(asyncPayloadRecord.iterator.return());
+        promises.push(asyncPayloadRecord.asyncIterator.return());
       }
     });
     return Promise.all(promises);
@@ -2280,15 +2280,15 @@ class StreamRecord {
   items: Array<unknown> | null;
   promise: Promise<void>;
   parentContext: AsyncPayloadRecord | undefined;
-  iterator: AsyncIterator<unknown> | undefined;
-  isCompletedIterator?: boolean;
+  asyncIterator: AsyncIterator<unknown> | undefined;
+  isCompletedAsyncIterator?: 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: AsyncPayloadRecord | undefined;
     exeContext: ExecutionContext;
   }) {
@@ -2297,7 +2297,7 @@ class StreamRecord {
     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.subsequentPayloads.add(this);
@@ -2322,8 +2322,8 @@ class StreamRecord {
     this._resolve?.(items);
   }
 
-  setIsCompletedIterator() {
-    this.isCompletedIterator = true;
+  setIsCompletedAsyncIterator() {
+    this.isCompletedAsyncIterator = true;
   }
 }