Custom bufferDebounce RxJS operator

buffer-debounce.ts

import { buffer, debounceTime, OperatorFunction, SchedulerLike } from 'rxjs';

/**
 * Emits buffered values from the source Observable only after a particular time span
 * has passed without another source emission.
 *
 * @param {number} dueTime The timeout duration in milliseconds (or the time
 * unit determined internally by the optional `scheduler`) for the window of
 * time required to wait for emission silence before emitting the buffered
 * source values.
 * @param {SchedulerLike} scheduler The {@link SchedulerLike} to use for
 * managing the timers that handle the timeout for each value.
 * @author https://stackoverflow.com/a/62598663
 */
export function bufferDebounce<T>(
  dueTime: number,
  scheduler?: SchedulerLike,
): OperatorFunction<T, T[]> {
  return (source) =>
    source.pipe(buffer(source.pipe(debounceTime(dueTime, scheduler))));
}