@antfu/p
Toolkit for managing multiple promises.
Without
const items = [1, 2, 3, 4, 5]
(await Promise.all(items
.map(async i => {
const v = await multiply(i, 3)
const even = await isEven(v)
return [even, v]
})))
.filter(x => x[0])
.map(x => x[1])
import P from '@antfu/p'
const items = [1, 2, 3, 4, 5]
await P(items)
.map(async i => await multiply(i, 3))
.filter(async i => await isEven(i))
// [6, 12]
import P from '@antfu/p'
const p = P()
// collect promises that are not necessarily needed to be resolved right away
p.add(promiseTask1)
someOtherTasks()
p.add(promiseTask2)
p.add(promiseTask3)
// resolve all collected promises
await p
// => Promise.all([promiseTask1, promiseTask2, promiseTask3])
import P from '@antfu/p'
// limits the number of concurrent tasks
await P(myTasks, { concurrency: 5 })
Sponsors
License
MIT License © 2021 Anthony Fu
11.8k Jan 2, 2023
929 Dec 31, 2022
83 Aug 11, 2022
3 May 18, 2022
4 May 3, 2022
14 Jan 3, 2023
24 Dec 22, 2022
8 Jun 7, 2022
6 Mar 29, 2022
20 Dec 30, 2022