/// import { ReadyState } from "../types"; import IOSocket from "../io.socket"; import PeerDataSocket from "./peer.data.socket"; import Peer from "./peer"; import Negotiator from "./negotiator"; import AigoSocket from "../helpers/aigo/aigo.socket"; type PeerAcceptSocket = PeerDataSocket; type PeerSocketOptions = { remoteAddress: string; localAddress?: string; }; /** * net.socket 数据加密传输封装类, 简单封装,方便数据的传输与读取,加解密 */ export default class PeerSocket extends IOSocket { readonly options: { peer: string; sessionId: string; provider: Peer; source: string; negotiator: Negotiator | null; }; private _readState; private _p2pSocket; get readyState(): ReadyState; get peer(): string; get provider(): Peer; get source(): string; get negotiator(): Negotiator | null; static get supportNative(): boolean; /** * 通道类型 * */ get channelType(): "p2p" | "psp"; get readableLength(): number; get writableLength(): number; constructor(socket: PeerAcceptSocket, options: { peer: string; sessionId: string; provider: Peer; source: string; negotiator: Negotiator | null; }); initChannel(channel: AigoSocket, options: PeerSocketOptions): void; private initEvent; protected onDataHandle(data: Buffer): Buffer; write(chunk: string | Buffer): boolean; } export {};