From f06bbad94b857332a6f82faaa0587c039583f064 Mon Sep 17 00:00:00 2001 From: Hazelnoot Date: Wed, 25 Jun 2025 14:09:48 -0400 Subject: [PATCH] implement CollapsedQueue.delete --- packages/backend/src/misc/collapsed-queue.ts | 8 ++++++++ 1 file changed, 8 insertions(+) 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();