- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 105 for Relay (0.29 sec)
-
samples/guide/src/main/java/okhttp3/recipes/ConfigureTimeouts.java
.callTimeout(10, TimeUnit.SECONDS) .build(); } public void run() throws Exception { Request request = new Request.Builder() .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay. .build(); try (Response response = client.newCall(request).execute()) { System.out.println("Response completed: " + response); } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Sep 28 18:00:26 UTC 2019 - 1.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java
*/ @Override ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit); /** * @since 15.0 (previously returned ScheduledFuture) */ @Override <V extends @Nullable Object> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit); /** * @since 15.0 (previously returned ScheduledFuture) */ @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Feb 11 17:30:04 UTC 2025 - 2.1K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/ConfigureTimeouts.kt
.callTimeout(10, TimeUnit.SECONDS) .build() fun run() { val request = Request .Builder() .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay. .build() client.newCall(request).execute().use { response -> println("Response completed: $response") } } } fun main() { ConfigureTimeouts().run()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.3K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/IntervalControlHelperTest.java
// Test with rule that has no delay helper.addIntervalRule("01:30", "15:15", "*", 0); start = System.currentTimeMillis(); helper.delayByRules(); end = System.currentTimeMillis(); assertTrue(end - start < 50); // Should return quickly // Test with rule that has delay (we'll use a very short delay for testing) helper.ruleList.clear();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 10 13:41:04 UTC 2025 - 13.1K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/CancelCall.kt
private val client = OkHttpClient() fun run() { val request = Request .Builder() .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay. .build() val startNanos = System.nanoTime() val call = client.newCall(request) // Schedule a job to cancel the call in 1 second. executor.schedule({
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt
* task should not be executed again. Otherwise it returns a delay until the next execution. * * A task has at most one next execution. If the same task instance is scheduled multiple times, the * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and * those implied by the returned execution delay. * * Cancellation * ------------ *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
@Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 6.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
notifyStopped(); } } /* * A NoOp service that will delay the startup and shutdown notification for a configurable amount * of time. */ private static class NoOpDelayedService extends NoOpService { private final long delay; NoOpDelayedService(long delay) { this.delay = delay; } @Override protected void doStart() { new Thread() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 20:34:52 UTC 2025 - 25.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/PerCallSettings.kt
import okhttp3.Request class PerCallSettings { private val client = OkHttpClient() fun run() { val request = Request .Builder() .url("http://httpbin.org/delay/1") // This URL is served with a 1 second delay. .build() // Copy to customize OkHttp for this request. val client1 = client .newBuilder() .readTimeout(500, TimeUnit.MILLISECONDS) .build()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.7K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PerCallSettings.java
private final OkHttpClient client = new OkHttpClient(); public void run() throws Exception { Request request = new Request.Builder() .url("http://httpbin.org/delay/1") // This URL is served with a 1 second delay. .build(); // Copy to customize OkHttp for this request. OkHttpClient client1 = client.newBuilder() .readTimeout(500, TimeUnit.MILLISECONDS) .build();
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun May 22 01:29:42 UTC 2016 - 1.9K bytes - Viewed (0)