Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 881 for futures (0.05 sec)

  1. .github/DISCUSSION_TEMPLATE/questions.yml

              * I already hit the "watch" button in this repository to receive notifications and I commit to help at least 2 people that ask questions in the future.
              * Review one Pull Request by downloading the code and following [all the review process](https://fastapi.tiangolo.com/help-fastapi/#review-pull-requests).
    
          options:
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Thu Aug 03 15:59:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  2. futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutures.java

       *       return value of this method as its cause
       * </ul>
       */
      public static
          Throwable
          tryInternalFastPathGetFailure(InternalFutureFailureAccess future) {
        return future.tryInternalFastPathGetFailure();
      }
    
      private InternalFutures() {}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Jan 18 02:54:30 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/TestPlatform.java

      /**
       * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long,
       * TimeUnit)} overload in order to test that method.
       */
      static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future)
          throws ExecutionException {
        checkState(future.isDone(), "Future was expected to be done: %s", future);
        try {
          return getUninterruptibly(future, 0, SECONDS);
        } catch (TimeoutException e) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java

    @GwtIncompatible
    public class MockFutureListener implements Runnable {
      private final CountDownLatch countDownLatch;
      private final ListenableFuture<?> future;
    
      public MockFutureListener(ListenableFuture<?> future) {
        this.countDownLatch = new CountDownLatch(1);
        this.future = future;
    
        future.addListener(this, directExecutor());
      }
    
      @Override
      public void run() {
        countDownLatch.countDown();
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri May 12 18:12:42 UTC 2023
    - 3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      }
    
      public void testCancel_notDoneNoInterrupt() throws Exception {
        Future<?> future = newFutureInstance();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertNull(tryInternalFastPathGetFailure(future));
        CancellationException e = assertThrows(CancellationException.class, () -> future.get());
        assertNotNull(e.getCause());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      }
    
      public void testCancel_notDoneNoInterrupt() throws Exception {
        Future<?> future = newFutureInstance();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertNull(tryInternalFastPathGetFailure(future));
        CancellationException e = assertThrows(CancellationException.class, () -> future.get());
        assertNotNull(e.getCause());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertFalse(future.isCancelled());
    
        ExecutorService executor = newSingleThreadExecutor();
    
        try {
          Future<Boolean> getResult = executor.submit(() -> future.get());
    
          // Release the future value.
          latch.countDown();
    
          assertTrue(getResult.get(10, SECONDS));
        } finally {
          executor.shutdownNow();
        }
    
        assertTrue(future.isDone());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  8. docs/en/docs/contributing.md

    Now let's say that you want to add a translation for the section [Features](features.md){.internal-link target=_blank}.
    
    * Copy the file at:
    
    ```
    docs/en/docs/features.md
    ```
    
    * Paste it in exactly the same location but for the language you want to translate, e.g.:
    
    ```
    docs/es/docs/features.md
    ```
    
    /// tip
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sat Jul 26 11:35:42 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  9. okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt

    import java.net.InetSocketAddress
    import java.net.ServerSocket
    import java.security.PrivateKey
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.Executors
    import java.util.concurrent.Future
    import javax.net.ServerSocketFactory
    import javax.net.SocketFactory
    import javax.net.ssl.SSLSocket
    import okhttp3.Handshake
    import okhttp3.Handshake.Companion.handshake
    import okhttp3.TestUtil.threadFactory
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ForwardingListenableFuture.java

    import java.util.concurrent.Executor;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link ListenableFuture} which forwards all its method calls to another future. Subclasses
     * should override one or more methods to modify the behavior of the backing future as desired per
     * the <a href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
     * <p>Most subclasses can just use {@link SimpleForwardingListenableFuture}.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top