| 1 | import { Observable } from 'rxjs';
|
| 2 | export interface WsMessageHandler<T = string> {
|
| 3 | message: T;
|
| 4 | callback: (...args: any[]) => Observable<any> | Promise<any>;
|
| 5 | }
|
| 6 | export interface WebSocketAdapter<TServer = any, TClient = any, TOptions = any> {
|
| 7 | create(port: number, options?: TOptions): TServer;
|
| 8 | bindClientConnect(server: TServer, callback: Function): any;
|
| 9 | bindClientDisconnect?(client: TClient, callback: Function): any;
|
| 10 | bindMessageHandlers(client: TClient, handlers: WsMessageHandler[], transform: (data: any) => Observable<any>): any;
|
| 11 | close(server: TServer): any;
|
| 12 | }
|