Skip to content

Commit 3dd9fb2

Browse files
committed
add additional cancellation sites
1 parent 9550c71 commit 3dd9fb2

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

src/execution/execute.ts

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1578,7 +1578,7 @@ function completeListItemValue(
15781578
}
15791579

15801580
async function completePromisedListItemValue(
1581-
item: unknown,
1581+
item: Promise<unknown>,
15821582
parent: GraphQLWrappedResult<Array<unknown>>,
15831583
exeContext: ExecutionContext,
15841584
itemType: GraphQLOutputType,
@@ -1589,7 +1589,9 @@ async function completePromisedListItemValue(
15891589
deferMap: ReadonlyMap<DeferUsage, DeferredFragmentRecord> | undefined,
15901590
): Promise<unknown> {
15911591
try {
1592-
const resolved = await item;
1592+
const resolved = await (exeContext.promiseCanceller?.withCancellation(
1593+
item,
1594+
) ?? item);
15931595
let completed = completeValue(
15941596
exeContext,
15951597
itemType,
@@ -2581,7 +2583,7 @@ function completeStreamItem(
25812583
fieldDetailsList,
25822584
info,
25832585
itemPath,
2584-
item,
2586+
exeContext.promiseCanceller?.withCancellation(item) ?? item,
25852587
incrementalContext,
25862588
new Map(),
25872589
).then(

0 commit comments

Comments
 (0)