decord/alpha/source/modules/coded_links/codedLinkQueue.tsx

25 lines
783 B
TypeScript
Raw Normal View History

2026-10-06 11:16:32 +00:00
// Module ID: 17592
// Function ID: 17593
// Name: codedLinkQueue
2026-10-06 11:16:32 +00:00
// Dependencies: [3, 17593, 2]
2026-07-20 16:05:17 +00:00
// Exports: queueMessageLinkFetch
2026-10-06 11:16:32 +00:00
// Module 17592 (codedLinkQueue)
import LoggerDefault from "Logger" /* 3 */;
2026-10-06 11:16:32 +00:00
import _modDef17593 from "module_17593" /* 17593 */;
2026-10-03 08:58:59 +00:00
import size from "module_2" /* 2 */;
2026-08-24 06:08:38 +00:00
const logger = new LoggerDefault("codedLinkQueue");
2026-10-03 08:58:59 +00:00
const tmp2 = new LoggerDefault("codedLinkQueue");
2026-10-06 11:16:32 +00:00
const obj = new _modDef17593({ concurrency: 5, intervalCap: 10, interval: 2000 });
2026-07-29 08:29:29 +00:00
obj.on("add", () => {
if (obj.size > 0) {
2026-08-24 06:08:38 +00:00
logger.warn("Message link fetch queue backlog:", tmp.size);
2026-07-20 16:05:17 +00:00
}
});
const result = size.fileFinishedImporting("modules/coded_links/codedLinkQueue.tsx");
2026-07-20 16:05:17 +00:00
export const queueMessageLinkFetch = function queueMessageLinkFetch(arg0) {
2026-07-29 08:29:29 +00:00
obj.add(arg0);
2026-07-20 16:05:17 +00:00
};