Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for withTimeout (0.05 sec)

  1. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

    import kotlinx.coroutines.coroutineScope
    import kotlinx.coroutines.job
    import kotlinx.coroutines.supervisorScope
    import kotlinx.coroutines.test.runTest
    import kotlinx.coroutines.withContext
    import kotlinx.coroutines.withTimeout
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketEffect
    import mockwebserver3.junit5.StartStop
    import okhttp3.Callback
    import okhttp3.FailingCall
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

        assertThat(f.get()).isEqualTo(2);
      }
    
      @J2ktIncompatible
      @GwtIncompatible // withTimeout
      public void testWithTimeout() throws Exception {
        ScheduledExecutorService executor = newScheduledThreadPool(1);
        try {
          FluentFuture<?> f =
              FluentFuture.from(SettableFuture.create()).withTimeout(0, SECONDS, executor);
          ExecutionException e = assertThrows(ExecutionException.class, () -> f.get());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

      @GwtIncompatible // ScheduledExecutorService
      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      public final FluentFuture<V> withTimeout(
          Duration timeout, ScheduledExecutorService scheduledExecutor) {
        return withTimeout(toNanosSaturated(timeout), TimeUnit.NANOSECONDS, scheduledExecutor);
      }
    
      /**
       * Returns a future that delegates to this future but will finish early (via a {@link
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Futures.java

      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      public static <V extends @Nullable Object> ListenableFuture<V> withTimeout(
          ListenableFuture<V> delegate, Duration time, ScheduledExecutorService scheduledExecutor) {
        return withTimeout(delegate, toNanosSaturated(time), TimeUnit.NANOSECONDS, scheduledExecutor);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
     *       Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
     *       beware: <i>Your {@code AsyncCallable} should not complete its {@code Future} until it is
     *       safe for the next task to start.</i>
     * </ul>
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 22.1K bytes
    - Viewed (0)
Back to top