/** @typedef {(error?: Error | null, data?: import('./types.js').MsgResponse) => void} TransformCallback */
export class MessageStream extends Transform {
    /**
     * @param {number} msgId
     * @param {import('readable-stream').TransformOptions} [options]
     */
    constructor(msgId: number, options?: import("readable-stream").TransformOptions);
    _msgId: number;
    _incomingObjectMode: boolean;
    override _transform(chunk: any, encoding: string, callback: TransformCallback): void;
    override _flush(callback: TransformCallback): void;
}
export type TransformCallback = (error?: Error | null, data?: import("./types.js").MsgResponse) => void;
import { Transform } from 'readable-stream';