We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c78bc1d commit dfcc4e5Copy full SHA for dfcc4e5
1 file changed
src/execution/IncrementalGraph.ts
@@ -157,11 +157,6 @@ export class IncrementalGraph {
157
subsequentResultRecord: SubsequentResultRecord,
158
): void {
159
this._rootNodes.delete(subsequentResultRecord);
160
- if (this._rootNodes.size === 0) {
161
- for (const resolve of this._nextQueue) {
162
- resolve({ value: undefined, done: true });
163
- }
164
165
}
166
167
private _addIncrementalDataRecords(
@@ -336,6 +331,11 @@ export class IncrementalGraph {
336
331
while ((completed = this._completedQueue.shift()) !== undefined) {
337
332
yield completed;
338
333
334
+ if (this._rootNodes.size === 0) {
335
+ for (const resolve of this._nextQueue) {
+ resolve({ value: undefined, done: true });
+ }
339
340
341
private _enqueue(completed: IncrementalDataRecordResult): void {
0 commit comments