- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 320 for TimeUnit (0.06 seconds)
-
okhttp-tls/src/test/java/okhttp3/tls/HeldCertificateTest.kt
import assertk.assertions.matches import java.math.BigInteger import java.security.KeyFactory import java.security.spec.PKCS8EncodedKeySpec import java.security.spec.X509EncodedKeySpec import java.util.concurrent.TimeUnit import okhttp3.testing.PlatformRule import okhttp3.tls.HeldCertificate.Companion.decode import okio.ByteString.Companion.decodeBase64 import org.bouncycastle.asn1.x509.GeneralName import org.junit.jupiter.api.Assertions.fail
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 22.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt
package okhttp3 import assertk.assertThat import assertk.assertions.containsExactly import java.util.concurrent.AbstractExecutorService import java.util.concurrent.RejectedExecutionException import java.util.concurrent.TimeUnit import okhttp3.internal.connection.RealCall import okhttp3.internal.finishedAccessor /** * A fake executor for testing that never executes anything! Instead, it just keeps track of what's * been enqueued. */
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Oct 06 18:34:01 GMT 2025 - 2.2K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/CancelCall.kt
* limitations under the License. */ package okhttp3.recipes.kt import java.io.IOException import java.util.concurrent.Executors import java.util.concurrent.TimeUnit import okhttp3.OkHttpClient import okhttp3.Request class CancelCall { private val executor = Executors.newScheduledThreadPool(1) private val client = OkHttpClient() fun run() { val request =Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt
fun withConnectTimeout( timeout: Int, unit: TimeUnit, ): Chain fun readTimeoutMillis(): Int fun withReadTimeout( timeout: Int, unit: TimeUnit, ): Chain fun writeTimeoutMillis(): Int fun withWriteTimeout( timeout: Int, unit: TimeUnit, ): Chain }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 3.5K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/PerCallSettings.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.recipes.kt import java.io.IOException import java.util.concurrent.TimeUnit import okhttp3.OkHttpClient import okhttp3.Request class PerCallSettings { private val client = OkHttpClient() fun run() { val request = Request .Builder()Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
import java.net.ServerSocket import java.net.Socket import java.net.SocketException import java.util.concurrent.CompletableFuture import java.util.concurrent.RejectedExecutionException import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import okhttp3.Call import okhttp3.Callback import okhttp3.DelegatingServerSocketFactory import okhttp3.DelegatingSocketFactory import okhttp3.OkHttpClient
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 6.4K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.jspecify.annotations.Nullable; /** * An executor service which forwards all its method calls to another executor service. Subclasses
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java
import static com.google.common.base.Preconditions.checkNotNull; import com.google.common.annotations.GwtCompatible; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.jspecify.annotations.Nullable; /** * {@link FluentFuture} that forwards all calls to a delegate. * * <h3>Extension</h3> *Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
: UNEXPECTED_HANG_DELAY_MILLIS; boolean hung = !awaitUninterruptibly(callCompletedLatch, hangDelayMillis, TimeUnit.MILLISECONDS); if (hung) { assertEquals(expectedOutcome, Outcome.HANG); } else { assertThat(task.get(UNEXPECTED_HANG_DELAY_MILLIS, TimeUnit.MILLISECONDS)).isNull(); } } @Override protected void tearDown() throws Exception {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 27.1K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/PerCallSettings.java
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.recipes; import java.io.IOException; import java.util.concurrent.TimeUnit; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; public final class PerCallSettings { private final OkHttpClient client = new OkHttpClient();Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun May 22 01:29:42 GMT 2016 - 1.9K bytes - Click Count (0)