/// <reference types="node" />
import { ConsumerGroupStream } from 'kafka-node';
import { Transform, TransformCallback } from 'stream';
import { ProgressMessage } from '../types';
export declare class StopOnFinishProgressTransform extends Transform {
    private consumerStream;
    private active;
    constructor(consumerStream: ConsumerGroupStream, active?: boolean);
    _transform(message: ProgressMessage, encoding: string, callback: TransformCallback): Promise<void>;
}