return false;

}

private shouldPruneIdleBucket(key: string): boolean {

const mappedBucketKey = this.routeBuckets.get(key);

return mappedBucketKey !== key && !this.hasBucketReference(key);

}

private bindRouteToBucket(routeKey: string, bucketKey: string): BucketState<TData> {

const target = this.getBucket(bucketKey);

target.routeKeys.add(routeKey);

break;

}

if (bucket.pending.length === 0) {

if (bucket.active === 0 && !this.routeBuckets.has(key) && !this.hasBucketReference(key)) {

if (bucket.active === 0 && this.shouldPruneIdleBucket(key)) {

this.buckets.delete(key);

}

continue;

]);

});

it("prunes idle route buckets after Discord bucket remapping", async () => {

const client = new RequestClient("test-token", {

fetch: async () =>

new Response(JSON.stringify({ id: "first" }), {

status: 200,

headers: { "X-RateLimit-Bucket": "channel-messages" },

}),

});

await expect(client.get("/channels/c1/messages")).resolves.toEqual({ id: "first" });

const metrics = client.getSchedulerMetrics();

expect(metrics.activeBuckets).toBe(1);

expect(metrics.buckets.map((bucket) => bucket.key)).toEqual(["channel-messages:channels/c1"]);

});

it("waits for a learned bucket reset before dispatching the next request", async () => {

vi.useFakeTimers();

vi.setSystemTime(0);