import { Observable } from 'rxjs'; import { AVCommand } from '../../command/AVCommand'; import { AVCommandResponse } from '../../command/AVCommandResponse'; import { IWebSocketClient } from '../IWebSocketClient'; export interface IRxWebSocketController { websocketClient: IWebSocketClient; onMessage: Observable; onState: Observable; open(url: string, protocols?: string | string[]): Observable; send(data: ArrayBuffer | string | Blob): void; execute(avCommand: AVCommand): Observable; }