|
1 | 1 | /**
|
2 |
| - * rubico v2.7.3 |
| 2 | + * rubico v2.7.4 |
3 | 3 | * https://github.com/a-synchronous/rubico
|
4 | 4 | * (c) 2019-2025 Richard Tong
|
5 | 5 | * rubico may be freely distributed under the MIT license.
|
@@ -40,11 +40,11 @@ const curry2 = function (baseFunc, arg0, arg1) {
|
40 | 40 |
|
41 | 41 | const reducerMap = (
|
42 | 42 | reducer, mapper,
|
43 |
| -) => function mappingReducer(result, reducerItem) { |
44 |
| - const mappingReducerItem = mapper(reducerItem) |
45 |
| - return isPromise(mappingReducerItem) |
46 |
| - ? mappingReducerItem.then(curry2(reducer, result, __)) |
47 |
| - : reducer(result, mappingReducerItem) |
| 43 | +) => function mappingReducer(result, reducerElement) { |
| 44 | + const mappingReducerElement = mapper(reducerElement) |
| 45 | + return isPromise(mappingReducerElement) |
| 46 | + ? mappingReducerElement.then(curry2(reducer, result, __)) |
| 47 | + : reducer(result, mappingReducerElement) |
48 | 48 | }
|
49 | 49 |
|
50 | 50 | // argument resolver for curry3
|
@@ -90,15 +90,15 @@ const always = value => function getter() { return value }
|
90 | 90 |
|
91 | 91 | const reducerFilter = (
|
92 | 92 | reducer, predicate,
|
93 |
| -) => function filteringReducer(result, item) { |
94 |
| - const shouldInclude = predicate(item) |
| 93 | +) => function filteringReducer(result, element) { |
| 94 | + const shouldInclude = predicate(element) |
95 | 95 | return isPromise(shouldInclude)
|
96 | 96 | ? shouldInclude.then(curry3(
|
97 | 97 | thunkConditional,
|
98 | 98 | __,
|
99 |
| - thunkify2(reducer, result, item), |
| 99 | + thunkify2(reducer, result, element), |
100 | 100 | always(result)))
|
101 |
| - : shouldInclude ? reducer(result, item) : result |
| 101 | + : shouldInclude ? reducer(result, element) : result |
102 | 102 | }
|
103 | 103 |
|
104 | 104 | const isArray = Array.isArray
|
@@ -392,11 +392,11 @@ const mapReduce = function (map, reducer, result) {
|
392 | 392 |
|
393 | 393 | const reducerConcat = (
|
394 | 394 | reducerA, reducerB,
|
395 |
| -) => function pipedReducer(result, item) { |
396 |
| - const intermediate = reducerA(result, item) |
| 395 | +) => function pipedReducer(result, element) { |
| 396 | + const intermediate = reducerA(result, element) |
397 | 397 | return isPromise(intermediate)
|
398 |
| - ? intermediate.then(curry2(reducerB, __, item)) |
399 |
| - : reducerB(intermediate, item) |
| 398 | + ? intermediate.then(curry2(reducerB, __, element)) |
| 399 | + : reducerB(intermediate, element) |
400 | 400 | }
|
401 | 401 |
|
402 | 402 | const genericReduce = function (collection, reducer, result) {
|
@@ -448,32 +448,32 @@ const reducerFlatMap = (
|
448 | 448 |
|
449 | 449 | const reducerForEach = (
|
450 | 450 | reducer, callback,
|
451 |
| -) => function executingForEach(result, item) { |
452 |
| - const operation = callback(item) |
| 451 | +) => function executingForEach(result, element) { |
| 452 | + const operation = callback(element) |
453 | 453 | if (isPromise(operation)) {
|
454 |
| - return operation.then(thunkify2(reducer, result, item)) |
| 454 | + return operation.then(thunkify2(reducer, result, element)) |
455 | 455 | }
|
456 |
| - return reducer(result, item) |
| 456 | + return reducer(result, element) |
457 | 457 | }
|
458 | 458 |
|
459 | 459 | const _reducerTryCatchErrorHandler = function (
|
460 |
| - catcher, reducer, error, accum, item, |
| 460 | + catcher, reducer, error, accum, element, |
461 | 461 | ) {
|
462 |
| - const c = catcher(error, item) |
| 462 | + const c = catcher(error, element) |
463 | 463 | return isPromise(c) ? c.then(curry2(reducer, accum, __)) : reducer(accum, c)
|
464 | 464 | }
|
465 | 465 |
|
466 | 466 | const reducerTryCatch = function (reducer, transducerTryer, catcher) {
|
467 | 467 | const finalReducer = transducerTryer(reducer)
|
468 |
| - return function errorHandlingReducer(accum, item) { |
| 468 | + return function errorHandlingReducer(accum, element) { |
469 | 469 | try {
|
470 |
| - const ret = finalReducer(accum, item) |
| 470 | + const ret = finalReducer(accum, element) |
471 | 471 | return isPromise(ret) ? ret.catch(curry5(
|
472 |
| - _reducerTryCatchErrorHandler, catcher, reducer, __, accum, item, |
| 472 | + _reducerTryCatchErrorHandler, catcher, reducer, __, accum, element, |
473 | 473 | )) : ret
|
474 | 474 | } catch (error) {
|
475 | 475 | return _reducerTryCatchErrorHandler(
|
476 |
| - catcher, reducer, error, accum, item, |
| 476 | + catcher, reducer, error, accum, element, |
477 | 477 | )
|
478 | 478 | }
|
479 | 479 | }
|
|
0 commit comments