Superglue MCP

export class PromiseQueue { private queue: Array<() => void> = []; private running = 0; constructor(private maxConcurrent: number) {} enqueue<T>(fn: () => Promise<T>): Promise<T> { return new Promise<T>((resolve, reject) => { const task = async () => { try { const result = await fn(); resolve(result); } catch (error) { reject(error); } finally { this.running--; this.processNext(); } }; if (this.running < this.maxConcurrent) { this.running++; task(); } else { this.queue.push(task); } }); } private processNext(): void { if (this.queue.length > 0 && this.running < this.maxConcurrent) { const task = this.queue.shift(); if (task) { this.running++; task(); } } } }