import { Observable } from 'rxjs'; export interface WebSocketAdapter { create(port: number, options?: T): any; bindClientConnect(server: any, callback: (...args) => void): any; bindClientDisconnect?(client: any, callback: (...args) => void): any; bindMessageHandlers(client: any, handlers: Array<{ message: any; callback: (...args: any[]) => Observable | Promise | any; }>, transform: (data: any) => Observable): any; close(server: any): any; }