retryWhen with promise

index.js

const { rxObserver } = require('api/v0.3');
const { defer } = require('rxjs');
const { retryWhen, tap, delay } = require('rxjs/operators');


defer(() => mockRequest()).pipe(
    retryWhen(errors$ =>
      errors$.pipe(
          tap(rxObserver('retries')),
          delay(10)
      )
    )
  )
  .subscribe(rxObserver('result'));


function mockRequest(){
  return new Promise((resolve, reject)=>{
    setTimeout(() => {
      if (Date.now() > 100) {
        resolve('OK');
      } else {
        reject('FAIL');
      }
    }, 10);
  });
}