reduce.md

Rx.Observable.prototype.reduce(accumulator, [seed])

Ⓢ

Applies an accumulator function over an observable sequence, returning the result of the aggregation as a single element in the result sequence. The specified seed value is used as the initial accumulator value.

For aggregation behavior with incremental intermediate results, see the scan method.

Arguments

1. accumulator (Function): An accumulator function to be invoked on each element.
2. [seed] (Any): The initial accumulator value.

Returns

(Observable): An observable sequence containing a single element with the final accumulator value.

Example

var source = Rx.Observable.range(1, 3)
    .reduce(function (acc, x) {
        return acc * x;
    }, 1)

var subscription = source.subscribe(
    function (x) {
        console.log('Next: ' + x);
    },
    function (err) {
        console.log('Error: ' + err);
    },
    function () {
        console.log('Completed');
    });

// => Next: 6
// => Completed

Location

File:

• /src/core/linq/observable/reduce.js

Dist:

• rx.all.js
• rx.all.compat.js
• rx.aggregates.js

Prerequisites:

• rx.lite.js | rx.compat.js | rx.lite.js | rx.lite.compat.js

NPM Packages:

• rx

NuGet Packages:

• RxJS-All
• RxJS-Aggregates

Unit Tests:

• /tests/observable/reduce.js