@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)); }
public Observable<ConnectionStatus> getConnectionStatus() { return Observable.create(observableFactory.getObservable(client)); }
RxLostApiClient { public Observable<ConnectionStatus> getConnectionStatus() { return Observable.create(observableFactory.getObservable(client)); } }
RxLostApiClient { public Observable<ConnectionStatus> getConnectionStatus() { return Observable.create(observableFactory.getObservable(client)); } RxLostApiClient(Context context);   RxLostApiClient(Context context, ApiClientFactory clientFactory,
      ObservableFactory observableFactory); }
RxLostApiClient { public Observable<ConnectionStatus> getConnectionStatus() { return Observable.create(observableFactory.getObservable(client)); } RxLostApiClient(Context context);   RxLostApiClient(Context context, ApiClientFactory clientFactory,
      ObservableFactory observableFactory); Observable<ConnectionStatus> getConnectionStatus(); }
RxLostApiClient { public Observable<ConnectionStatus> getConnectionStatus() { return Observable.create(observableFactory.getObservable(client)); } RxLostApiClient(Context context);   RxLostApiClient(Context context, ApiClientFactory clientFactory,
      ObservableFactory observableFactory); Observable<ConnectionStatus> getConnectionStatus();  }