BaseRx { static final void onResolutionResult(int resultCode, ConnectionResult connectionResult) { for(BaseRx observable : observableSet) { observable.handleResolutionResult(resultCode, connectionResult); } observableSet.clear(); } protected  BaseRx(@NonNull RxFit rxFit, Long timeout, TimeUnit timeUnit); protected  BaseRx(@NonNull Context ctx, @NonNull Api<? extends Api.ApiOptions.NotRequiredOptions>[] services, Scope[] scopes);   }
@Test public void onResolutionResult() { BaseRx<Object> baseRx = spy(new BaseRx<Object>(ctx, null, null) { @Override protected void handleResolutionResult(int resultCode, ConnectionResult connectionResult) {} }); BaseRx.observableSet.add(baseRx); BaseRx.onResolutionResult(0, connectionResult); verify(baseRx).handleResolutionResult(0, connectionResult); assertEquals(0, BaseRx.observableSet.size()); }