most retry

const set = [0, 1, 2];
const retry = n => stream => stream.recoverWith(e => n === 0 ? most.throwError(e) : retry(n - 1, stream));

let i = 0;

most.from(set)
  .tap(x => {
    if (i === 0 && x === 2)
    {
      i++;
      throw new Error('2 !')
    };
  })
  .thru(retry(1))
  .observe(x => console.log(x))
  .then(() => console.log('complete'))
  .catch(err => console.error(err));