rxjs-pausable-example

rxjs-pausable-example.ts

import { pausable, PausableObservable } from 'rxjs-pausable';

const source = interval(1000).pipe(
  map(x => `Hello ${x}!`),
  pauseable()
) as PausableObservable<string>;
 
source.subscribe(console.log);

setTimeout(() => source.pause(), 5000)
  
/**
 * Output:
 *  Hello 0!
 *  Hello 1!
 *  Hello 2!
 *  Hello 3!
 *  Hello 4!
/*