/** * Batch Processor for Queue Operations * * Efficiently processes operations in batches to reduce overhead * and improve throughput. */ import type { BatchProcessorConfig, QueueOperation } from '@plyaz/types/api'; /** * Batch processor implementation */ export declare class BatchProcessor { private batch; private timer?; private readonly config; private processing; constructor(config: BatchProcessorConfig); /** * Add operation to the current batch */ add(operation: QueueOperation): void; /** * Schedule batch flush */ private scheduleFlush; /** * Flush the current batch */ flush(): Promise; /** * Get current batch size */ size(): number; /** * Clear pending batch */ clear(): void; /** * Destroy the processor */ destroy(): void; } //# sourceMappingURL=BatchProcessor.d.ts.map