import { Writable } from 'stream';

type Task = (...args: any) => Promise<void>;
declare class RingPromise {
    private ring;
    private index;
    private readonly task;
    constructor(ringSize: number, task: Task);
    run(...arg: any): Promise<void>;
    stream(): Writable;
}

export { RingPromise };