From 08c29c8e82111fff58d514b1cca36d4bb78e7b7f Mon Sep 17 00:00:00 2001 From: TheBeastLT Date: Sun, 25 Jan 2026 12:27:35 +0200 Subject: [PATCH] update concurrency --- addon/addon.js | 2 +- addon/moch/moch.js | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/addon/addon.js b/addon/addon.js index 184b45a..785e953 100644 --- a/addon/addon.js +++ b/addon/addon.js @@ -19,7 +19,7 @@ const STALE_ERROR_AGE = 7 * 24 * 60 * 60; // 7 days const builder = new addonBuilder(dummyManifest()); const requestQueue = createNamedQueue(Infinity); -const newLimiter = pLimit(30) +const newLimiter = pLimit(50) builder.defineStreamHandler((args) => { if (!args.id.match(/tt\d+/i) && !args.id.match(/kitsu:\d+/i)) { diff --git a/addon/moch/moch.js b/addon/moch/moch.js index 36d4351..a6f9e5b 100644 --- a/addon/moch/moch.js +++ b/addon/moch/moch.js @@ -79,7 +79,7 @@ export const MochOptions = { const unrestrictQueues = {} Object.values(MochOptions) .map(moch => moch.key) - .forEach(mochKey => unrestrictQueues[mochKey] = createNamedQueue(20)); + .forEach(mochKey => unrestrictQueues[mochKey] = createNamedQueue(40)); export function hasMochConfigured(config) { return Object.keys(MochOptions).find(moch => config?.[moch])