/**
 * Adapted from batchWithTimeOrCount, with added support for flush.
 */
export declare function batchWithTimeOrCount(ms: number, n: number): (err: any, x: any, push: any, next: any) => void;
export declare function flush(stream: any): void;
/**
 * Split a batched stream on a specific field.
 *
 * @param {string} onField
 */
export declare function splitBatch(onField: string): (err: any, x: any, push: any, next: any) => void;