Skip to content

Commit a2adbc1

Browse files
committed
Simplify collectFields for @defer & @stream
1 parent e081838 commit a2adbc1

File tree

9 files changed

+412
-461
lines changed

9 files changed

+412
-461
lines changed

src/execution/IncrementalPublisher.ts

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import type {
88
GraphQLFormattedError,
99
} from '../error/GraphQLError.js';
1010

11-
import type { GroupedFieldSet } from './collectFields.js';
11+
import type { DeferUsage, GroupedFieldSet } from './collectFields.js';
1212

1313
interface IncrementalUpdate<TData = unknown, TExtensions = ObjMap<unknown>> {
1414
pending: ReadonlyArray<PendingResult>;
@@ -786,6 +786,7 @@ export class DeferredGroupedFieldSetRecord {
786786
/** @internal */
787787
export class DeferredFragmentRecord {
788788
path: ReadonlyArray<string | number>;
789+
deferUsage: DeferUsage;
789790
label: string | undefined;
790791
id: string | undefined;
791792
children: Set<SubsequentResultRecord>;
@@ -795,9 +796,10 @@ export class DeferredFragmentRecord {
795796
pendingSent?: boolean;
796797
_pending: Set<DeferredGroupedFieldSetRecord>;
797798

798-
constructor(opts: { path: Path | undefined; label: string | undefined }) {
799+
constructor(opts: { path: Path | undefined; deferUsage: DeferUsage }) {
799800
this.path = pathToArray(opts.path);
800-
this.label = opts.label;
801+
this.label = opts.deferUsage.label;
802+
this.deferUsage = opts.deferUsage;
801803
this.children = new Set();
802804
this.filtered = false;
803805
this.deferredGroupedFieldSetRecords = new Set();

0 commit comments

Comments
 (0)