asyncPipe.js

const asyncPipe = (...fns) => arg => {
  const res = fns[0](arg)
  const slice = fns.slice(1)
  const next = slice.length ? asyncPipe(...slice) : identity
  const isPromise = typeof res === 'object' && 'then' in res
  return isPromise ? res.then(next) : next(res)
}

const add = a => b => a + b

asyncPipe(
  Promise.resolve, 
  add(1), 
  Promise.resolve, 
  Promise.resolve, 
  add(1)
)(1)  // 3