reduce.parallel

[richytong]

Reducer<T> = (any, T)=>Promise|any
Foldable<T> = Iterable<T>|AsyncIterable<T>|{ reduce: Reducer<T>=>any }|Object<T>

reduce.parallel(
  reducer (any, any)=>Promise|any,
  result any,
)(value Foldable) -> Promise|any

reduce in parallel. Reduction happens by order of asynchronous resolution.

reduce.parallel(
  async (total, number) => {
    await Promise(resolve => setTimeout(resolve, number))
    return total + number
  },
  0,
)([1, 2, 3]).then(console.log) // 6