/// <reference types="node" />
/// <reference types="node" />
import tls from 'tls';
import type { demux } from './generated';
import { BaseEmitter } from './typed-emitter';
export interface DemuxSocketProps {
    host: string;
    startRequestId: number;
    timeout: number;
    tlsConnectionOptions?: tls.ConnectionOptions;
}
export declare type DemuxSocketEvents = {
    connectionData: (connectionId: number, connectionData: Buffer) => void;
    push: (payload: demux.Downstream & protobuf.Message) => void;
};
export declare class DemuxSocket extends BaseEmitter<DemuxSocketEvents> {
    private host;
    private debug;
    private currentRequestId;
    private timeout;
    private tlsConnectionOptions?;
    socket?: tls.TLSSocket;
    private pendingRequestResponses;
    private incomingPayloadBuffer;
    private incomingPayloadLength;
    constructor(props: DemuxSocketProps);
    private getSocket;
    private write;
    private handleDownstreamData;
    request(payload: Omit<demux.Req, 'requestId'>): Promise<demux.Rsp & protobuf.Message>;
    push(payload: demux.Push): Promise<void>;
    destroy(error?: Error | undefined): Promise<void>;
}