import 'mingo/init/system';
import { AbstractAggregator, PipelineOperator } from '@tashmet/engine';
import { Logger } from '@tashmet/core';
import { Document } from '@tashmet/tashmet';
import { Options } from 'mingo/core';
import { CollectionBuffer } from './buffer.js';
export declare function preparePipeline(pipeline: Document[]): Document[];
export declare class MingoStreamAggregator<T extends Document> extends AbstractAggregator<T> {
    private options;
    private buffer;
    private logger;
    private pipelineOperators;
    constructor(pipeline: Document[], options: Options, buffer: CollectionBuffer, logger: Logger, pipelineOperators: Record<string, PipelineOperator<any>>);
    stream<TResult>(input: AsyncIterable<T>): AsyncGenerator<TResult>;
}