f

Author: yaacovCR

src/execution/Executor.ts

@@ -256,11 +256,11 @@ export class Executor<
     } else {
       this.sharedExecutionContext = sharedExecutionContext;
     }
-    const { getAbortSignal, getAsyncHelpers, getRegisterCleanup, promiseAll } =
+    const { getAbortSignal, getAsyncHelpers, getTrackPromise, promiseAll } =
       this.sharedExecutionContext;
     this.getAbortSignal = getAbortSignal;
     this.getAsyncHelpers = getAsyncHelpers;
-    this.trackPromise = getRegisterCleanup();
+    this.trackPromise = getTrackPromise();
     this.promiseAll = promiseAll;
   }
 

src/execution/createSharedExecutionContext.ts

@@ -12,7 +12,7 @@ export interface SharedExecutionContext {
     values: ReadonlyArray<PromiseOrValue<T>>,
   ) => Promise<Array<T>>;
   getAsyncHelpers: () => GraphQLResolveInfoHelpers;
-  getRegisterCleanup: () => (cleanup: Promise<unknown>) => void;
+  getTrackPromise: () => (cleanup: Promise<unknown>) => void;
 }
 
 export function createSharedExecutionContext(
@@ -28,7 +28,7 @@ export function createSharedExecutionContext(
     | (<T>(values: ReadonlyArray<PromiseOrValue<T>>) => Promise<T>)
     | undefined;
 
-  const getRegisterCleanup = (): ((cleanup: Promise<unknown>) => void) =>
+  const getTrackPromise = (): ((cleanup: Promise<unknown>) => void) =>
     (trackPromise ??= (cleanup) => {
       asyncWorkTracker.add(cleanup);
     });
@@ -70,14 +70,14 @@ export function createSharedExecutionContext(
       get promiseRace() {
         return getPromiseRace();
       },
-      trackPromise: getRegisterCleanup(),
+      trackPromise: getTrackPromise(),
     });
 
   return {
     asyncWorkTracker,
     getAbortSignal: () => abortSignal,
     promiseAll,
     getAsyncHelpers,
-    getRegisterCleanup,
+    getTrackPromise,
   };
 }

src/execution/incremental/IncrementalExecutor.ts

@@ -735,7 +735,7 @@ export class IncrementalExecutor<
               abortStreamItem(reason);
             }
             if (isAsync) {
-              this.sharedExecutionContext.getRegisterCleanup()(
+              this.sharedExecutionContext.getTrackPromise()(
                 returnIteratorCatchingErrors(
                   iterator as AsyncIterator<unknown>,
                 ),