Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 105 for Relay (0.29 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top