in src/lib/utils/queue.ts [20:42]
private async processQueue(): Promise<void> {
if (this.isProcessing) {
return;
}
this.isProcessing = true;
while (this.queue.length > 0) {
const queueItem = this.queue.shift()!;
try {
const { asyncFunction, resolve } = queueItem;
const result = await asyncFunction();
resolve(result);
} catch (error) {
console.error("Error processing queue item:", error);
const { reject } = queueItem;
reject(error);
}
}
this.isProcessing = false;
}