TimeUnit - Code Search

okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

    dispatcher.enqueue(
      MockResponse
        .Builder()
        .bodyDelay(10, TimeUnit.SECONDS)
        .body("abc")
        .build(),
    )
    dispatcher.enqueue(
      MockResponse
        .Builder()
        .bodyDelay(10, TimeUnit.SECONDS)
        .body("def")
        .build(),
    )
    dispatcher.enqueue(
      MockResponse(body = "ghi"),

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Sat Nov 01 12:18:11 GMT 2025

- 67.4K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

import java.net.Proxy
import java.net.ProxySelector
import java.net.Socket
import java.time.Duration
import java.util.Random
import java.util.concurrent.ExecutorService
import java.util.concurrent.TimeUnit
import java.util.concurrent.TimeUnit.MILLISECONDS
import javax.net.SocketFactory
import javax.net.ssl.HostnameVerifier
import javax.net.ssl.SSLSocketFactory
import javax.net.ssl.X509TrustManager
import kotlin.time.Duration as KotlinDuration

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Tue Oct 07 21:55:03 GMT 2025

- 51.4K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

    server.enqueue(
      MockResponse
        .Builder()
        .headersDelay(responseHeadersStartDelay, TimeUnit.MILLISECONDS)
        .bodyDelay(responseBodyStartDelay, TimeUnit.MILLISECONDS)
        .throttleBody(5, responseBodyEndDelay, TimeUnit.MILLISECONDS)
        .body("fghijk")
        .build(),
    )
    call.execute().use { response ->

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Wed Nov 05 18:28:35 GMT 2025

- 70.5K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/api/android/okhttp.api

	public final fun maxAge (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
	public final fun maxAge-LRDsOJo (J)Lokhttp3/CacheControl$Builder;
	public final fun maxStale (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
	public final fun maxStale-LRDsOJo (J)Lokhttp3/CacheControl$Builder;
	public final fun minFresh (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Wed Nov 05 18:28:35 GMT 2025

- 70.3K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/Futures.java

      AsyncCallable<O> callable,
      long delay,
      TimeUnit timeUnit,
      ScheduledExecutorService executorService) {
    TrustedListenableFutureTask<O> task = TrustedListenableFutureTask.create(callable);
    Future<?> scheduled = executorService.schedule(task, delay, timeUnit);
    /*
     * Even when the user interrupts the task, we pass `false` to `cancel` so that we don't

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 64.3K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/api/jvm/okhttp.api

	public final fun maxAge (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
	public final fun maxAge-LRDsOJo (J)Lokhttp3/CacheControl$Builder;
	public final fun maxStale (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
	public final fun maxStale-LRDsOJo (J)Lokhttp3/CacheControl$Builder;
	public final fun minFresh (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Wed Nov 05 18:28:35 GMT 2025

- 70.2K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

    stream.readTimeout().timeout(500, TimeUnit.MILLISECONDS)
    val startNanos = System.nanoTime()
    assertFailsWith<InterruptedIOException> {
      stream.takeHeaders()
    }
    val elapsedNanos = System.nanoTime() - startNanos
    awaitWatchdogIdle()
    // 200ms delta
    assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedNanos).toDouble())
      .isCloseTo(500.0, 200.0)

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Thu Jul 31 04:18:40 GMT 2025

- 75.5K bytes

- Click Count (0)

github.com/codelibs/fess-crawler

fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

                .register("https", sslSocketFactory)
                .build();

        final long timeToLive = getInitParameter(TIME_TO_LIVE_PROPERTY, 5L, Long.class);
        final TimeUnit timeUnit = TimeUnit.valueOf(getInitParameter(TIME_TO_LIVE_TIME_UNIT_PROPERTY, "MINUTES", String.class));
        final int maxTotal = getInitParameter(MAX_TOTAL_CONNECTION_PROPERTY, 200, Integer.class);

Created: Sat Dec 20 11:21:39 GMT 2025

- Last Modified: Sun Nov 23 12:19:14 GMT 2025

- 53.7K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/cache/CacheBuilder.java

import static com.google.common.base.Preconditions.checkArgument;
import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Preconditions.checkState;
import static java.util.concurrent.TimeUnit.NANOSECONDS;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.base.Ascii;
import com.google.common.base.Equivalence;

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Wed Oct 08 18:55:33 GMT 2025

- 51.9K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/cache/CacheBuilder.java

import static com.google.common.base.Preconditions.checkArgument;
import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Preconditions.checkState;
import static java.util.concurrent.TimeUnit.NANOSECONDS;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.base.Ascii;
import com.google.common.base.Equivalence;

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Wed Oct 08 18:55:33 GMT 2025

- 51.6K bytes

- Click Count (0)

Search Options