reduce.pool

[richytong]

reduce.pool(maxConcurrency number, foldable Foldable, init function|any) -> Promise|any

reduce with limited concurrency.

// (from number, to number) => AsyncIterator<number>
const asyncRange = async function* (from, to) {
  let number = from
  while (++number < to) {
    yield number
  }
}

const asyncAdd = async (a, b) => a + b

reduce.pool(20, map(tap(console.log))(asyncAdd), 0)(asyncRange(1, 1000)).then(console.log)
// 1
// 2
// 3
// ...
// 999
// 499499