add todos

Author: yaacovCR

src/execution/Canceller.ts

@@ -29,10 +29,6 @@ export class Canceller {
   }
 
   withCancellation<T>(originalPromise: Promise<T>): Promise<T> {
-    if (this.abortSignal === undefined) {
-      return originalPromise;
-    }
-
     const { promise, resolve, reject } = promiseWithResolvers<T>();
     const abort = () => reject(this.abortSignal.reason);
     this._aborts.add(abort);

src/execution/IncrementalPublisher.ts

@@ -127,6 +127,7 @@ class IncrementalPublisher {
       IteratorResult<SubsequentIncrementalExecutionResult, void>
     > => {
       if (isDone) {
+        this._context.canceller?.unsubscribe();
         await this._returnAsyncIteratorsIgnoringErrors();
         return { value: undefined, done: true };
       }
@@ -173,6 +174,8 @@ class IncrementalPublisher {
         batch = await this._incrementalGraph.nextCompletedBatch();
       } while (batch !== undefined);
 
+      // TODO: add test for this case
+      /* c8 ignore next */
       this._context.canceller?.unsubscribe();
       await this._returnAsyncIteratorsIgnoringErrors();
       return { value: undefined, done: true };

src/execution/execute.ts

@@ -379,6 +379,8 @@ export function experimentalExecuteQueryOrMutationOrSubscriptionEvent(
     }
     return buildDataResponse(exeContext, graphqlWrappedResult);
   } catch (error) {
+    // TODO: add test case for synchronous null bubbling to root with cancellation
+    /* c8 ignore next */
     exeContext.canceller?.unsubscribe();
     return { data: null, errors: withError(exeContext.errors, error) };
   }
@@ -2205,6 +2207,8 @@ function executeSubscription(
       const promise = canceller?.withCancellation(result) ?? result;
       return promise.then(assertEventStream).then(
         (resolved) => {
+          // TODO: add test case
+          /* c8 ignore next */
           canceller?.unsubscribe();
           return resolved;
         },