/// export interface Aggregator { input: (x: T) => void; check: () => T2; } export interface AggregateHandler { handle(x: T): Promise; tryNext(): boolean; nextAggregate(): Promise; } export declare function createAggregateHandler(aggregator: Aggregator): AggregateHandler;