| /** PURE_IMPORTS_START _scan,_takeLast,_defaultIfEmpty,_util_pipe PURE_IMPORTS_END */ |
| import { scan } from './scan'; |
| import { takeLast } from './takeLast'; |
| import { defaultIfEmpty } from './defaultIfEmpty'; |
| import { pipe } from '../util/pipe'; |
| export function reduce(accumulator, seed) { |
| if (arguments.length >= 2) { |
| return function reduceOperatorFunctionWithSeed(source) { |
| return pipe(scan(accumulator, seed), takeLast(1), defaultIfEmpty(seed))(source); |
| }; |
| } |
| return function reduceOperatorFunction(source) { |
| return pipe(scan(function (acc, value, index) { return accumulator(acc, value, index + 1); }), takeLast(1))(source); |
| }; |
| } |
| //# sourceMappingURL=reduce.js.map |
