///
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;