Skip to main content
Module

x/rimbu/mod.ts>AsyncReducer.combine

Rimbu is a TypeScript library focused on immutable, performant, and type-safe collections and other tools.
rimbu-org/rimbu
Go to Latest
function AsyncReducer.combine
import { AsyncReducer } from "https://deno.land/x/rimbu@1.1.0/mod.ts";
const { combine } = AsyncReducer;

Returns a Reducer that combines multiple input reducers according to the given "shape" by providing input values to all of them and collecting the outputs in the shape.

Examples

Example 1

const red = Reducer.combine([Reducer.sum, { av: [Reducer.average] }])
console.log(Stream.range({amount: 9 }).reduce(red))
// => [36, { av: [4] }]

Parameters

shape: S & AsyncReducer.CombineShape<T>
  • a shape defining where reducer outputs will be located in the result. It can consist of a single reducer, an array of shapes, or an object with string keys and shapes as values.