Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 277 for TimeUnit (0.05 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionPool.kt

        keepAliveDuration: Long = 5,
        timeUnit: TimeUnit = TimeUnit.MINUTES,
        taskRunner: TaskRunner = TaskRunner.INSTANCE,
        connectionListener: ConnectionListener = ConnectionListener.NONE,
      ) : this(
        RealConnectionPool(
          taskRunner = taskRunner,
          maxIdleConnections = maxIdleConnections,
          keepAliveDuration = keepAliveDuration,
          timeUnit = timeUnit,
          connectionListener = connectionListener,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

            .addHeader("Last-Modified: " + formatDate(-1, TimeUnit.HOURS))
            .addHeader("Expires: " + formatDate(1, TimeUnit.HOURS))
            .body("ABC")
            .build(),
        )
        server.enqueue(
          MockResponse
            .Builder()
            .addHeader("Last-Modified: " + formatDate(-5, TimeUnit.MINUTES))
            .addHeader("Expires: " + formatDate(2, TimeUnit.HOURS))
            .body("DEF")
            .build(),
        )
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Oct 03 17:41:45 GMT 2025
    - 116.8K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/CacheControlJvmTest.kt

      fun completeBuilder() {
        val cacheControl =
          CacheControl
            .Builder()
            .noCache()
            .noStore()
            .maxAge(1, TimeUnit.SECONDS)
            .maxStale(2, TimeUnit.SECONDS)
            .minFresh(3, TimeUnit.SECONDS)
            .onlyIfCached()
            .noTransform()
            .immutable()
            .build()
        assertThat(cacheControl.toString()).isEqualTo(
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  4. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java

    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Nov 20 08:44:44 GMT 2025
    - 17K bytes
    - Click Count (0)
  5. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt

        assertThat(server.takeRequest(0, TimeUnit.MILLISECONDS)).isNull()
        assertThat(result).isEqualTo(listOf(address("157.240.1.18")))
    
        assertThat(cacheEvents()).containsExactly(CacheHit::class)
    
        result = cachedDns.lookup("www.google.com")
        assertThat(result).containsExactly(address("157.240.1.18"))
        recordedRequest = server.takeRequest(0, TimeUnit.MILLISECONDS)!!
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       * Invokes {@code executor.}{@link ExecutorService#awaitTermination(long, TimeUnit)
       * awaitTermination(long, TimeUnit)} uninterruptibly.
       *
       * @since 30.0
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @SuppressWarnings("GoodTime")
      public static boolean awaitTerminationUninterruptibly(
          ExecutorService executor, long timeout, TimeUnit unit) {
        boolean interrupted = false;
        try {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.8K bytes
    - Click Count (0)
  7. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

        assertEquals(0, ticker.read());
        assertEquals(10, ticker.read());
        assertEquals(20, ticker.read());
    
        for (TimeUnit timeUnit : TimeUnit.values()) {
          ticker.setAutoIncrementStep(0, timeUnit);
          assertEquals(
              "Expected no auto-increment when setting autoIncrementStep to 0 " + timeUnit,
              30,
              ticker.read());
        }
      }
    
      public void testAutoIncrement_negative() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  8. guava/src/com/google/common/base/Stopwatch.java

    import static java.util.concurrent.TimeUnit.DAYS;
    import static java.util.concurrent.TimeUnit.HOURS;
    import static java.util.concurrent.TimeUnit.MICROSECONDS;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.MINUTES;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    
    import com.google.common.annotations.GwtCompatible;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

            .Builder()
            .headersDelay(1500, TimeUnit.MILLISECONDS)
            .build(),
        )
        val request =
          Request
            .Builder()
            .url(server.url("/"))
            .post(DelayedRequestBody("hello".toRequestBody(null), 1500, TimeUnit.MILLISECONDS))
            .build()
        client =
          client
            .newBuilder()
            .readTimeout(1000, TimeUnit.MILLISECONDS)
            .build()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        long lastInitialDelay;
        long lastDelay;
        TimeUnit lastUnit;
    
        void assertLastMethodCalled(String method, long delay, TimeUnit unit) {
          assertEquals(method, lastMethodCalled);
          assertEquals(delay, lastDelay);
          assertEquals(unit, lastUnit);
        }
    
        void assertLastMethodCalled(String method, long initialDelay, long delay, TimeUnit unit) {
          assertEquals(method, lastMethodCalled);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 7.4K bytes
    - Click Count (0)
Back to Top