/// import EventEmitter from "eventemitter3"; import { StreamEvent } from "./types"; import ISocket from "./isocket"; /** * */ export default class TransformSocket extends EventEmitter implements ISocket { private _readable; private _writerable; private readonly _id; private readonly _sessionId; type: "accept" | "connect"; get id(): string; get sessionId(): string; get writable(): boolean; get readable(): boolean; get remoteAddress(): string; get remotePort(): number; get localAddress(): string; get localPort(): number; get destroyed(): boolean; get readableLength(): number; get writableLength(): number; private writer; private reader; constructor(); get readyState(): "open" | "closed"; isPaused(): boolean; private init; private initEvent; read(ttl?: number): Promise; /** * 往网络里写数据 * @param socket 网络连接socket * @param chunk 数据 * @param callback 写完之后回调,并告知写子多少内容, (chunkSize: number)=>{} */ write(chunk: Buffer | string): boolean; end(chunk?: Buffer | string): void; pipe(socket: ISocket): ISocket; pause(): void; resume(): void; destroy(err?: Error): void; close(err?: Error): void; setTimeout(ttl: number): void; setKeepAlive(enable: boolean, initialDelay: number): void; }