import { IPublishToConcurrency } from './concurrency';
type IKeyType = string | number | undefined;
type IGetKey<T> = (message: T) => IKeyType | Promise<IKeyType>;
type IKeyedConcurrencyOptions = {
    workerConcurrency: number;
};
export declare function KeyedConcurrency<T>(maxConcurrency: number, getKey: IGetKey<T>, worker: (message: T) => Promise<any>, { workerConcurrency }?: Partial<IKeyedConcurrencyOptions>): IPublishToConcurrency<T>;
export {};