QuestQueue

Una cola de tareas asíncronas con la concurrencia limitada. A la vez corren como mucho simultaneous tareas; las demás esperan, y cada vez que una termina se libera un hueco. Úsala para subidas o peticiones en lote: cualquier cosa que no puedas lanzar toda de golpe.

API

new QuestQueue({ simultaneous })

Parámetro	Descripción	Tipo	Por defecto
`simultaneous`	Concurrencia máxima; `<= 0` equivale a 1	`number`	`1`

Miembro	Descripción
`add(task)`	Encola una tarea y devuelve su propia promesa de resultado. Arranca cuando haya hueco
`allSettled(tasks)`	Encola un lote; se resuelve como `Promise.allSettled`, en el orden de entrada
`onIdle()`	Espera a que la cola se vacíe
`clear()`	Descarta todo lo que no haya arrancado (las tareas en curso siguen)
`running` / `pending` / `executed` / `idle`	Contadores en vivo

Ejemplo

import { QuestQueue } from 'ranuts';

const queue = new QuestQueue({ simultaneous: 3 });
const results = await Promise.all(urls.map((url) => queue.add(() => fetch(url))));

// O lánzalas y olvídate; luego espera a todo, fallos incluidos
urls.forEach((url) => queue.add(() => fetch(url)).catch(report));
await queue.onIdle();

Notas

FIFO: las tareas corren en el orden en que se añadieron.
Un fallo no atasca la cola. Cada tarea rechaza su propia promesa y la siguiente arranca igual.
Una tarea que lanza de forma síncrona también se captura, así que no se escapa de add() ni deja bloqueado el contador de concurrencia.
allSettled conserva el orden de entrada e informa de cada resultado por separado.