### Question:
RxLostApiClient { public Observable<ConnectionStatus> getConnectionStatus() { return Observable.create(observableFactory.getObservable(client)); } RxLostApiClient(Context context);   RxLostApiClient(Context context, ApiClientFactory clientFactory,
      ObservableFactory observableFactory); Observable<ConnectionStatus> getConnectionStatus();  }### Answer:
@Test public void getConnectionStatus() throws Exception { when(observableFactory.getObservable(apiClient)).thenReturn( new DisposableConnectionStatusEmitter(apiClient)); Observable observable = client.getConnectionStatus(); assertThat(observable).isNotNull(); verify(observableFactory).getObservable(clientFactory.getClient(context)); }