Async Composition

compose.js

const R = require('ramda')

const maybeFoo = next => async item => {
  console.log('maybeFoo', item)
  item.data++
  return next(item)
}

const maybeBar = next => async item => {
  console.log('maybeBar', item)
  item.data++
  return next(item)
}

const maybeBaz = next => async item => {
  console.log('maybeBaz', item)
  item.data += 50
  return item
}

const LTI = R.compose(maybeFoo, maybeBar, maybeBaz)

const main = async () => {

  const input = { data: 97 }

  const root = item => {
    return {
      data: 'fallback'
    }
  }

  const res = await LTI(root)(input)
  console.log('res', res)
}

main().catch(console.log)