gx提交

chenyc

2025-12-09 65e034683b28d799e73c7d7e5e4769fab5b9bc9c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
import { Duplex, type Transform } from 'readable-stream';
import { type IClientOptions } from './client';
export declare function writev(chunks: {
    chunk: any;
    encoding: string;
}[], cb: (err?: Error) => void): void;
export declare class BufferedDuplex extends Duplex {
    socket: WebSocket;
    private proxy;
    private isSocketOpen;
    private writeQueue;
    constructor(opts: IClientOptions, proxy: Transform, socket: WebSocket);
    _read(size?: number): void;
    _write(chunk: any, encoding: string, cb: (err?: Error) => void): void;
    _final(callback: (error?: Error) => void): void;
    _destroy(err: Error, callback: (error: Error) => void): void;
    socketReady(): void;
    private writeToProxy;
    private processWriteQueue;
}