@orche/reduce

Overview

Async reduction utility for async iterables with support for index-aware accumulation.

Features

• Async-first design
• Index-aware reduction
• Flexible accumulator patterns
• Promise-based accumulation
• Zero dependencies
• ESM support

Installation

# npm
$ npm install @orche/reduce

# yarn
$ yarn add @orche/reduce

# pnpm
$ pnpm add @orche/reduce

Usage

import { asyncReduce } from '@orche/reduce'

// Basic sum reduction
const asyncIterable = async function* () {
  yield 1
  yield 2
  yield 3
}

const sum = await asyncReduce(asyncIterable(), (acc, x) => acc + x, 0)
// => 6

// Index-aware reduction
const indexedSum = await asyncReduce(
  asyncIterable(),
  (acc, x, i) => acc + x * i,
  0
)
// => 0*1 + 1*2 + 2*3 = 8

// Async accumulator
const asyncSum = await asyncReduce(
  asyncIterable(),
  async (acc, x) => (await acc) + x,
  Promise.resolve(0)
)
// => 6

License

BSD-3-Clause