caroso1222 · December 12, 2018 04:46
diff --git a/rxjs-pausable-example.ts b/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!
 /*
	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!
	/*