管道函数

同步

const pipe = (...fns) => (input) => fns.reduce((chain, func) => func(chain), input);

const pipe = (...functions) => (input) => functions.reduce((chain, func) => func(chain), input);

const pipe = (...functions) => (value) => {
	 return functions.reduce((currentValue, currentFunction) => {
		 return currentFunction(currentValue);
	 }, value);
 };

异步 js

export const pipeAsync = (...fns) => (input) => fns.reduce((chain, func) => chain.then(func), Promise.resolve(input));

异步 ts

export const pipeAsync: any = (...fns: Promise<Function>[]) => (input: any) => fns.reduce((chain: Promise<Function>, func: Function | Promise<Function> | any) => chain.then(func), Promise.resolve(input));

使用说明

const a = (value) => {
    console.log('a_' + value)
    return 'a_' + value
}
const b = (value) => {
    console.log('b_' + value)
    return 'b_' + value
}
const c = (value) => {
    console.log('c_' + value)
    return 'c_' + value
}
// 调用管道函数
pipe(a,b,c)('rxh')
// 调用函数a
a_rxh
// 调用函数b，并将a的结果传给b
b_a_rxh
// 调用函数c，并将b的结果传给c
c_b_a_rxh
// 最终输出结果
'c_b_a_rxh'