rxjs debounced buffer operator

debouncedBuffer.ts

export const debouncedBufferTime = <T extends object>(
  time: number
) => (
  observable: Observable<T>
): Observable<T[]> => {
    const messageSubject = new Subject<1>();
    const debouncedMessage$ = messageSubject.pipe(debounceTime(time));

    return observable.pipe(
      tap(() => messageSubject.next(1)),
      buffer(debouncedMessage$),
    );
  }