SOURCE

function getInfo() {
	return new Promise((reslove, reject) => {
    const x = Math.random() > 0.7;
    if(x) {
        console.info("res")
        reslove(x)
    }else {
        console.info("err")
        reject(x)
    }
  })
}


Rx.Observable.defer(getInfo)
              // .retry(2)
              .retryWhen(err$ => err$.delay(1000).take(3))
              .subscribe(v => console.info(v),
                        err => console.warn(err)
                        )