RxJS Example 03

rxjs-example-03.ts

import {fromEvent} from 'rxjs/internal/observable/fromEvent';
import {interval} from 'rxjs/internal/observable/interval';
import {buffer, filter, map} from 'rxjs/operators';

let stream$ = fromEvent(document.getElementById('hit-me') as HTMLElement, 'click');

stream$
  .pipe(
    buffer(interval(3000)),
    map((val: number[]) => val.length),
    filter((x: number) => x > 1)
  )
  .subscribe((val: number) => {
    console.log(val)
  });