import './polyfill-promise-with-resolvers'; import type { SchedulerFn } from '../server/lib/schedule-on-next-tick'; type CacheKeyFn = (key: K) => PromiseLike | C; type BatcherOptions = { cacheKeyFn?: CacheKeyFn; schedulerFn?: SchedulerFn; }; type WorkFn = (key: C, resolve: (value: V | PromiseLike) => void) => Promise; /** * A wrapper for a function that will only allow one call to the function to * execute at a time. */ export declare class Batcher { private readonly cacheKeyFn?; /** * A function that will be called to schedule the wrapped function to be * executed. This defaults to a function that will execute the function * immediately. */ private readonly schedulerFn; private readonly pending; protected constructor(cacheKeyFn?: CacheKeyFn | undefined, /** * A function that will be called to schedule the wrapped function to be * executed. This defaults to a function that will execute the function * immediately. */ schedulerFn?: SchedulerFn); /** * Creates a new instance of PendingWrapper. If the key extends a string or * number, the key will be used as the cache key. If the key is an object, a * cache key function must be provided. */ static create(options?: BatcherOptions): Batcher; static create(options: BatcherOptions & Required, 'cacheKeyFn'>>): Batcher; /** * Wraps a function in a promise that will be resolved or rejected only once * for a given key. This will allow multiple calls to the function to be * made, but only one will be executed at a time. The result of the first * call will be returned to all callers. * * @param key the key to use for the cache * @param fn the function to wrap * @returns a promise that resolves to the result of the function */ batch(key: K, fn: WorkFn): Promise; } export {};