1234567891011121314151617181920212223
/** Run a callback concurrently with all the elements of an Iterable */export async function concurrent<Type>(  iterable: AsyncIterable<Type> | Iterable<Type>,  iteratorFn: (arg: Type) => Promise<unknown>,  limit = 200,) {  const executing: Promise<unknown>[] = [];
  for await (const item of iterable) {    const p: Promise<unknown> = iteratorFn(item).then(() =>      executing.splice(executing.indexOf(p), 1)    );
    executing.push(p);
    if (executing.length >= limit) {      await Promise.race(executing);    }  }
  await Promise.all(executing);}