function retry(fx, cb, checkFn) {

  const left = createStore(10)

  const fxData = restore(fx, {})

​

  const shouldReturnFromRetry = combine(

    left,

    fxData,

    (left, fxData) => !left || checkFn(fxData)

  )

​

  left.on(fx.finally, x => x - 1)

​

  // left.watch(console.log)

  // fxData.watch(console.log)

  // shouldReturnFromRetry.watch(console.log)

​

  guard({

    source: fx.doneData,

    filter: shouldReturnFromRetry.map(s => !s),

    target: fx,

  })

​

  guard(fx.doneData, {

    filter: shouldReturnFromRetry,

  }).watch(cb)

​

  fx()

}

​

const fetchUserReposFx = createEffect()

​

fetchUserReposFx.use(async _ => {

  const req = await fetch('https://jsonplaceholder.typicode.com/todos/1')

  return req.json()

})

​

const checkFn = fxData =>

  fxData === 'OK' || fxData === 'ERROR' || 'id' in fxData

​

retry(fetchUserReposFx, console.log, checkFn)

​