delayAtLeast RxJS Pipe

delayAtLeast.ts

import { combineLatest, map, Observable, timer } from 'rxjs';

/**
 * Delay at least (RxJS operator)
 *
 * @param delayInMs Delay in ms
 */
export const delayAtLeast = <T>(delayInMs: number) => {
  return (observable: Observable<T>) => {
    return combineLatest([timer(delayInMs), observable]).pipe(
      map(([, observableResult]) => {
        return observableResult;
      }),
    );
  };
};