source: class ClientRetryPolicyTest {
  
      private final static int TIMEOUT;
  
      @Test(groups = "unit")
      public void onBeforeSendRequestNotInvoked() {
  
target:         RetryOptions retryOptions = new RetryOptions();
          GlobalEndpointManager endpointManager = Mockito.mock(GlobalEndpointManager.class);
  
          Mockito.doReturn(Completable.complete()).when(endpointManager).refreshLocationAsync(Mockito.eq(null), Mockito.eq(false));
          ClientRetryPolicy clientRetryPolicy = new ClientRetryPolicy(endpointManager, true, retryOptions);
  
          Exception exception = ReadTimeoutException.INSTANCE;
  
          RxDocumentServiceRequest dsr = RxDocumentServiceRequest.createFromName(
                  OperationType.Create, "/dbs/db/colls/col/docs/docId", ResourceType.Document);
          dsr.requestContext = Mockito.mock(DocumentServiceRequestContext.class);
  
          Single<IRetryPolicy.ShouldRetryResult> shouldRetry = clientRetryPolicy.shouldRetry(exception);
          validateSuccess(shouldRetry, ShouldRetryValidator.builder()
                  .withException(exception)
                  .shouldRetry(false)
                  .build());
  
          Mockito.verifyZeroInteractions(endpointManager);
      }
  
  }