windowCount

windowCount operator creates a new branch of observable from source observable every X count.

Example: windowCount operator

import { interval } from 'rxjs';
import { windowCount, take } from 'rxjs/operators';

const click$ = interval(1500).pipe(take(12));
const result$ = click$.pipe(windowCount(3));

Official Doc: rxjs.windowCount