Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 34 for SettableFuture (0.05 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      private Class<?> settableFutureClass;
      private Class<?> abstractFutureClass;
    
      @Override
      protected void setUp() throws Exception {
        // Load the "normal" copy of SettableFuture and related classes.
        SettableFuture<?> unused = SettableFuture.create();
        // Hack to load AbstractFuture et. al. in a new classloader so that it re-reads the cancellation
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

      public void testFromFluentFuture() {
        FluentFuture<String> f = FluentFuture.from(SettableFuture.create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
      public void testFromFluentFuturePassingAsNonFluent() {
        ListenableFuture<String> f = FluentFuture.from(SettableFuture.create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java

      protected static final Exception EXCEPTION = new Exception("Test exception");
    
      protected SettableFuture<Integer> inputFuture;
      protected ListenableFuture<T> resultFuture;
      protected MockFutureListener listener;
    
      @Override
      protected void setUp() throws Exception {
        super.setUp();
    
        inputFuture = SettableFuture.create();
        resultFuture = buildChainingFuture(inputFuture);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        assertThrows(CancellationException.class, () -> getUnchecked(future));
      }
    
      public void testGetUnchecked_executionExceptionChecked() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        assertThrows(CancellationException.class, () -> getUnchecked(future));
      }
    
      public void testGetUnchecked_executionExceptionChecked() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      protected static final int SLOW_OUTPUT_VALID_INPUT_DATA = 2;
      protected static final int SLOW_FUNC_VALID_INPUT_DATA = 3;
      private static final String RESULT_DATA = "SUCCESS";
    
      private SettableFuture<String> outputFuture;
      // Signals that the function is waiting to complete
      private CountDownLatch funcIsWaitingLatch;
      // Signals the function so it will complete
      private CountDownLatch funcCompletionLatch;
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      protected static final int SLOW_OUTPUT_VALID_INPUT_DATA = 2;
      protected static final int SLOW_FUNC_VALID_INPUT_DATA = 3;
      private static final String RESULT_DATA = "SUCCESS";
    
      private SettableFuture<String> outputFuture;
      // Signals that the function is waiting to complete
      private CountDownLatch funcIsWaitingLatch;
      // Signals the function so it will complete
      private CountDownLatch funcCompletionLatch;
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  8. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
     *       create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer
     *       {@link AbstractFuture}.)
     * </ul>
     *
     * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link
     * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
     *       create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer
     *       {@link AbstractFuture}.)
     * </ul>
     *
     * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link
     * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
     *       create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer
     *       {@link AbstractFuture}.)
     * </ul>
     *
     * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link
     * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
Back to top