RxJS pauseable

index.js

import Rx from 'rxjs/Rx';

var pauser = new Rx.Subject();

var source = Rx.Observable.interval(1000);
var pauseable = pauser.switchMap(paused => paused ? Rx.Observable.never() : source);

pauseable.subscribe(n => console.log('next', n), e => console.log('error', e), c => console.log('complete', c));

pauser.next(false);

setTimeout(() => pauser.next(true), 5000);
setTimeout(() => pauser.next(false), 10000);