interface WsMessageHandler<T = string> {
  message: T
  callback: (...args: any[]) => Observable<any> | Promise<any>
}