- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RetryHttpInitializerWrapper (0.28 sec)
-
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/RetryHttpInitializerWrapper.java
private static final long DEFAULT_READ_TIMEOUT_MILLIS = TimeUnit.MINUTES.toMillis(2); private final Supplier<Credential> credentialSupplier; private final Sleeper sleeper; RetryHttpInitializerWrapper(Supplier<Credential> credentialSupplier) { this(credentialSupplier, Sleeper.DEFAULT); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 4.6K bytes - Viewed (0) -
platforms/software/resources-gcs/src/test/groovy/org/gradle/internal/resource/transport/gcp/gcs/RetryHttpInitializerWrapperTest.groovy
return credential } } def "initialize should configure request for retries"() { given: def retryHttpInitializerWrapper = new RetryHttpInitializerWrapper(credentialSupplier) def storage = new Storage(transport, jsonFactory, retryHttpInitializerWrapper) def retryCount = 0 when: httpResponse.statusCode = 401 storage.objects().list("test").executeUnparsed()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 3.4K bytes - Viewed (0) -
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/GcsClient.java
if (gcsConnectionProperties.requiresAuthentication()) { Supplier<Credential> credentialSupplier = getCredentialSupplier(transport, jsonFactory); builder.setHttpRequestInitializer(new RetryHttpInitializerWrapper(credentialSupplier)); } if (gcsConnectionProperties.getEndpoint().isPresent()) { builder.setRootUrl(gcsConnectionProperties.getEndpoint().get().toString()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 22 11:17:20 UTC 2024 - 7.9K bytes - Viewed (0)