We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ab52e2f commit 5c7d4d1Copy full SHA for 5c7d4d1
src/execution/IncrementalGraph.ts
@@ -309,19 +309,12 @@ export class IncrementalGraph {
309
}
310
311
312
- private *_yieldCurrentCompletedIncrementalData(
313
- first: IncrementalDataRecordResult,
314
- ): Generator<IncrementalDataRecordResult> {
315
- yield first;
316
- yield* this.currentCompletedBatch();
317
- }
318
-
319
private _enqueue(completed: IncrementalDataRecordResult): void {
+ this._completedQueue.push(completed);
320
const next = this._nextQueue.shift();
321
- if (next !== undefined) {
322
- next(this._yieldCurrentCompletedIncrementalData(completed));
+ if (next === undefined) {
323
return;
324
325
- this._completedQueue.push(completed);
+ next(this.currentCompletedBatch());
326
327
0 commit comments