diff --git a/packages/backend/src/misc/collapsed-queue.ts b/packages/backend/src/misc/collapsed-queue.ts index a2b1166faf..63779100c8 100644 --- a/packages/backend/src/misc/collapsed-queue.ts +++ b/packages/backend/src/misc/collapsed-queue.ts @@ -47,6 +47,14 @@ export class CollapsedQueue { } } + delete(key: K) { + const job = this.jobs.get(key); + if (job) { + clearTimeout(job.timer); + this.jobs.delete(key); + } + } + async performAllNow() { const entries = [...this.jobs.entries()]; this.jobs.clear();