RxFit { public Completable checkConnection() { return Completable.fromObservable(Observable.create(new CheckConnectionObservable(this))); } RxFit(@NonNull Context ctx, @NonNull Api<? extends Api.ApiOptions.NotRequiredOptions>[] apis, @NonNull Scope[] scopes);  RxFit(@NonNull Context ctx, @NonNull Api<? extends Api.ApiOptions.NotRequiredOptions>[] apis, @NonNull Scope[] scopes, boolean handleResolutions); void setDefaultTimeout(long time, @NonNull TimeUnit timeUnit); void resetDefaultTimeout(); Completable checkConnection(); Ble ble(); Config config(); Goals goals(); History history(); Recording recording(); Sensors sensors(); Sessions sessions();  }
@Test public void checkConnection() { final Observable<Void> observable = Observable.empty(); PowerMockito.mockStatic(Observable.class, invocation -> observable); ArgumentCaptor<CheckConnectionObservable> captor = ArgumentCaptor.forClass(CheckConnectionObservable.class); rxFit.checkConnection(); PowerMockito.verifyStatic(times(1)); Observable.create(captor.capture()); CheckConnectionObservable checkConnectionObservable = captor.getValue(); assertNotNull(checkConnectionObservable); }