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