import { ICounter } from './conter';
export type IConcurrencyResultResolver = () => Promise<any>;
export type IPublishToConcurrency<T> = ((message: T) => Promise<IConcurrencyResultResolver>) & {
    finish: () => Promise<void>;
    counter: ICounter;
    quantity: ICounter;
};
export declare function Concurrency<Input, Output = any>(maxConcurrency: number, worker: (message: Input) => Promise<Output>): IPublishToConcurrency<Input>;