import { Observable } from 'rxjs'; export interface IRxWebSocketClient { state: string; onState: Observable; onMessage: Observable; open(url: string, protocols?: string | string[]): Observable; close(code?: number, data?: any): void; send(data: any, options?: any): Observable; }