forked from waja/action-debian-package
32 lines
963 B
JavaScript
32 lines
963 B
JavaScript
import _forceReduced from "./_forceReduced.js";
|
|
import _isArrayLike from "./_isArrayLike.js";
|
|
import _reduce from "./_reduce.js";
|
|
import _xfBase from "./_xfBase.js";
|
|
|
|
var preservingReduced = function (xf) {
|
|
return {
|
|
'@@transducer/init': _xfBase.init,
|
|
'@@transducer/result': function (result) {
|
|
return xf['@@transducer/result'](result);
|
|
},
|
|
'@@transducer/step': function (result, input) {
|
|
var ret = xf['@@transducer/step'](result, input);
|
|
return ret['@@transducer/reduced'] ? _forceReduced(ret) : ret;
|
|
}
|
|
};
|
|
};
|
|
|
|
var _flatCat = function _xcat(xf) {
|
|
var rxf = preservingReduced(xf);
|
|
return {
|
|
'@@transducer/init': _xfBase.init,
|
|
'@@transducer/result': function (result) {
|
|
return rxf['@@transducer/result'](result);
|
|
},
|
|
'@@transducer/step': function (result, input) {
|
|
return !_isArrayLike(input) ? _reduce(rxf, result, [input]) : _reduce(rxf, result, input);
|
|
}
|
|
};
|
|
};
|
|
|
|
export default _flatCat; |