import type { JobBatchResponse, JobResponse } from './types';
declare type ConsumeJobsFn<Job, Result> = (job: Job[]) => Promise<JobResponse<Job, Result>[]>;
export default class MachinatQueue<Job, Result> {
    currentSeq: number;
    private _queuedJobs;
    private _waitingRequets;
    private _jobListeners;
    private _finishJobsReducerCallback;
    private _failJobsReducerCallback;
    constructor();
    onJobs(listener: (queue: MachinatQueue<Job, Result>) => void): void;
    removeJobsListener(listenerToRemove: (queue: MachinatQueue<Job, Result>) => void): boolean;
    private _emitJobEvent;
    peekAt(idx: number): undefined | Job;
    acquireAt(idx: number, count: number, consume: ConsumeJobsFn<Job, Result>): Promise<undefined | JobResponse<Job, Result>[]>;
    acquire(count: number, consume: (jobs: Job[]) => Promise<JobResponse<Job, Result>[]>): Promise<undefined | JobResponse<Job, Result>[]>;
    private _enqueueJobs;
    executeJobs(jobs: Job[]): Promise<JobBatchResponse<Job, Result>>;
    get length(): number;
    private _finishJobs;
    private _finishJobsReducer;
    private _failJobs;
    private _failJobsReducer;
    private _removeJobsOfRequest;
}
export {};