Function throttleStrategy

packages/db/src/strategies/throttleStrategy.ts:48–68

(
  options: ThrottleStrategyOptions,
)

 * ```
 */
export function throttleStrategy(
  options: ThrottleStrategyOptions,
): ThrottleStrategy {
  const throttler = new LiteThrottler(
    (callback: () => Transaction) => callback(),
    options,
  )

  return {
    _type: `throttle`,
    options,
    execute: <T extends object = Record<string, unknown>>(
      fn: () => Transaction<T>,
    ) => {
      throttler.maybeExecute(fn as () => Transaction)
    },
    cleanup: () => {
      throttler.cancel()
    },
  }
}