mergeScan - 1

RxJS 5 mergeScan

by Huy Le

HTML

<script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>

JavaScript

console.clear();

const click$ = Rx.Observable
	.fromEvent(document, 'click')
	.mapTo(1);
  
const timer$ = (a,c) => Rx.Observable
	.timer(1000, (a+c)*1000);
  
const count$ = click$
	.mergeScan((a,c) => timer$(a,c).take(10), 0);

count$.subscribe(console.log);