import EventEmitter from "eventemitter3"; export declare enum WebSocketPluginWorkerCMD { Connect = "_ipipe.websocket.connect_", ResponseData = "_ipipe.websocket.response.data_", ResponseClose = "_ipipe.websocket.response.close_", ResponseOpen = "_ipipe.websocket.response.open_", ResponseError = "_ipipe.websocket.response.error_", RequestData = "_ipipe.websocket.request.data_", RequestClose = "_ipipe.websocket.request.close_", RequestOpen = "_ipipe.websocket.request.open_", RequestError = "_ipipe.websocket.request.error_" } export type WSWorkerMsg = { cmd: WebSocketPluginWorkerCMD; sid: string; connectId: string; data: any; }; type MessageSocketEvent = { data: (data: any) => void; close: () => void; open: () => void; error: (err: Error) => void; }; /** 给后台发送message请求的封装类 */ export declare class MessageSocket extends EventEmitter { readonly worker: Worker | Window; private connectId; private handleMessage; constructor(worker: Worker | Window); connect(url: string): void; close(): void; send(data: any): void; private poseMsg; } type WSWorkerEvent = { message: (ev: { type: "message"; data: any; }) => void; error: (ev: { type: "error"; error: Error; }) => void; open: (ev: { type: "open"; }) => void; close: (ev: { type: "close"; }) => void; }; export default class WSWorker extends EventEmitter { readonly url: string; private socket; private open; onmessage: (ev: { type: "message"; data: any; }) => void; onclose: (ev: { type: "close"; }) => void; onerror: (ev: { type: "error"; error: any; }) => void; onopen: (ev: { type: "open"; }) => void; get writable(): boolean; get readable(): boolean; get destroyed(): boolean; get isOpen(): boolean; get readyState(): number; isPaused(): boolean; constructor(url: string); private connect; private initEvent; addEventListener(event: keyof WSWorkerEvent, handle: (...args: any[]) => void): void; send(data: any): void; close(): void; } export {};