m3u8stream/dist/queue.d.ts

declare type Callback = (err?: Error, result?: any) => void;
interface Task {
    item: {};
    callback: Callback;
}
export default class Queue {
    _worker: (item: any, cb: Callback) => void;
    _concurrency: number;
    tasks: Task[];
    total: number;
    active: number;
    /**
     * A really simple queue with concurrency.
     */
    constructor(worker: (item: any, cb: Callback) => void, options?: {
        concurrency?: number;
    });
    /**
     * Push a task to the queue.
     */
    push(item: any, callback?: Callback): void;
    /**
     * Process next job in queue.
     */
    _next(): void;
    /**
     * Stops processing queued jobs.
     */
    die(): void;
}
export {};