const clicks$ = Rx.Observable.fromEvent(document, 'click'); const innerObservable$ = Rx.Observable.interval(1000); clicks$.switchMap(event => innerObservable$) .subscribe(val => console.log(val));