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 c9db779 commit cfbe5a4Copy full SHA for cfbe5a4
src/execution/IncrementalPublisher.ts
@@ -285,7 +285,6 @@ export class IncrementalPublisher {
285
continue;
286
}
287
288
- this._delete(child);
289
child.filtered = true;
290
291
if (isStreamItemsRecord(child)) {
@@ -333,12 +332,6 @@ export class IncrementalPublisher {
333
332
this._trigger();
334
335
336
- private _delete(item: SubsequentDataRecord) {
337
- this._released.delete(item);
338
- this._pending.delete(item);
339
- this._trigger();
340
- }
341
-
342
private _getIncrementalResult(
343
completedRecords: ReadonlySet<SubsequentDataRecord>,
344
): SubsequentIncrementalExecutionResult | undefined {
0 commit comments