import { Observable } from 'rxjs';

export interface ConnectableClient {
  connect: () => Promise<void>;
  close: () => void | Promise<void>;
  status: Observable<string>;
}