1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

  import { fromEvent, Subject } from 'rxjs';
  // eslint-disable-next-line object-curly-newline
  import { debounceTime, mapTo, scan, map } from 'rxjs/operators';
  import jquery from 'jquery';

  const counter$ = new Subject();
  counter$
    .pipe(
      scan((n, acc) => n + acc, 0),
      debounceTime(100),
    )
    .subscribe((count) => jquery('#count').text(count));

  const counter2$ = new Subject();
  counter2$
    .pipe(scan((n, acc) => n + acc, 0))
    .subscribe((count) => jquery('#count2').text(count));

  const increase$ = fromEvent(jquery('#increase'), 'click').pipe(mapTo(1));
  const decrease$ = fromEvent(jquery('#decrease'), 'click').pipe(mapTo(-1));

  increase$.subscribe(counter$);

  increase$.pipe(map((n) => n * 10)).subscribe(counter2$);

  decrease$.subscribe(counter$);

  decrease$.pipe(map((n) => n * 10)).subscribe(counter2$);