export type TaskQueueOptions = { batchSize: number; processItem: (item: Item) => unknown; }; export declare class TaskQueue { readonly options: TaskQueueOptions; _subs: ((item: Item) => void)[]; items: Item[]; isPaused: boolean; isProcessing: boolean; constructor(options: TaskQueueOptions); push(item: Item): void; remove(item: Item): void; subscribe(subscriber: (item: Item) => void): () => void; process(): Promise; stop(): void; start(): void; clear(): void; } //# sourceMappingURL=TaskQueue.d.ts.map