import { ReplicationConcurrencyController } from './concurrency-controller';
/**
 * Uses a semaphore to execute up to a given amount of messages in parallel. Any
 * additional message waits until a currently processed message finishes.
 * @returns The controller to acquire and release the semaphore and to cancel all semaphores
 */
export declare const createReplicationSemaphoreConcurrencyController: (maxParallel: number) => ReplicationConcurrencyController;
//# sourceMappingURL=create-semaphore-concurrency-controller.d.ts.map