Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for permit (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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 = !noNewExchanges
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  7. 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();
        }
    
        @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top