console.clear();

​

const { Observable } = Rx;

​

const source = Observable.interval(100).publish();

source.connect();

​

// Start with false, change to true after 200ms, then false again

// after another 200ms

const pauser = Observable.timer(200)

  .mapTo(true)

  .concat(Observable.timer(200).mapTo(false))

  .startWith(false);

​

const pausable = pauser

  .switchMap(paused => (paused ? Observable.never() : source))

  .take(10);

​

pausable.subscribe(x => console.log(x));

​