Switch sources on timeout

index.js

const { chart } = require('rp-api');
const { from, timer } = require('rxjs');
const { delayWhen, share, map, timeout, catchError, repeat, take } = require('rxjs/operators');

const source$ = from([ 5, 20, 25, 30, 42, 45 ])
  .pipe(
    delayWhen(timer)
    , share()
  );

const timer$ = timer(0, 5)
  .pipe(
    map(x => 't:' + x)
    , share()
  );

const output$ = source$
  .pipe(
    timeout(2)
    , catchError(()=>
      timer$
        .takeUntil(source$)
        .merge(source$.take(1))
    )
    , repeat()
    , take(10)
  );
  
timer$.take(10).subscribe(chart.createRxObserver());
source$.subscribe(chart.createRxObserver());
output$.subscribe(chart.createRxObserver());

Run at https://observable-playground.github.io/gist/c14c6642424e485de51ab1c8c2d979be