- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for permit (0.04 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring secondary permit", r.tryAcquire()); } public void testDoubleMinValueCanAcquireExactlyOnce() { RateLimiter r = RateLimiter.create(Double.MIN_VALUE, stopwatch); assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring an additional permit", r.tryAcquire());
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring secondary permit", r.tryAcquire()); } public void testDoubleMinValueCanAcquireExactlyOnce() { RateLimiter r = RateLimiter.create(Double.MIN_VALUE, stopwatch); assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring an additional permit", r.tryAcquire());
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 21.9K bytes - Viewed (0) -
LICENSES/vendor/github.com/Masterminds/semver/v3/LICENSE
in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Sat Nov 01 08:52:09 UTC 2025 - 1.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt
* * https://github.com/square/okhttp/pull/7190 */ @Test fun preferCallConnectionOverDeferredConnection() { // Make sure we have enough connection options to permit retries. dnsResults = listOf( localhostIpv4, localhostIpv6, TestUtil.UNREACHABLE_ADDRESS_IPV4.address, ) serverIpv4.protocols = listOf(Protocol.H2_PRIOR_KNOWLEDGE)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 10.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* * Since connections may be reused, the proxy selection, DNS, and connect events may not be present * for a call. In future releases of OkHttp these events may also occur concurrently to permit * multiple routes to be attempted simultaneously. * * Events and sequences of events may be repeated for retries and follow-ups. *
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:03:04 UTC 2025 - 24.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
noNewExchanges = true routeFailureCount++ } } e.errorCode == ErrorCode.CANCEL && call.isCanceled() -> { // Permit any number of CANCEL errors on locally-canceled calls. } else -> { // Everything else wants a fresh connection. noNewExchangesEvent = !noNewExchangesRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:55:03 UTC 2025 - 14.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
public static class AdjustablePolicy extends Policy { Permissions perms = new Permissions(); AdjustablePolicy(Permission... permissions) { for (Permission permission : permissions) perms.add(permission); } void addPermission(Permission perm) { perms.add(perm); } void clearPermissions() { perms = new Permissions(); } @OverrideRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:07:52 UTC 2025 - 37.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CookieTest.kt
.name("a") .value("b") .domain("example.com") .sameSite(sameSite) .build() assertThat(cookie.sameSite).isEqualTo(sameSite) } /** Note that we permit building a cookie that doesn’t follow the rules. */ @Test fun builderSameSiteNoneDoesNotRequireSecure() { val cookieBuilder = Cookie .Builder() .name("a") .value("b")
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 01 12:18:11 UTC 2025 - 24.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
} body.awaitSuccess() } /** * Duplex calls that have follow-ups are weird. By the time we know there's a follow-up we've * already split off another thread to stream the request body. Because we permit at most one * exchange at a time we break the request stream out from under that writer. */ @Test fun duplexWithRedirect() { enableProtocol(Protocol.HTTP_2)Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 25.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt
* } else { * // The resource was not cached. * } * ``` * * This technique works even better in situations where a stale response is better than no response. * To permit stale cached responses, use the `max-stale` directive with the maximum staleness in * seconds: * * ```java * Request request = new Request.Builder() * .cacheControl(new CacheControl.Builder()Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Oct 03 17:41:45 UTC 2025 - 26.8K bytes - Viewed (0)