Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 36 for SettableFuture (0.2 sec)

  1. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  2. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  3. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.await(latch);
        assertEquals(0, latch.getCount());
      }
    
      public void testAwaitDone_future() {
        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object unused =
            new Object() {
              @SuppressWarnings({"removal", "Finalize"}) // b/260137033
              @Override
              protected void finalize() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

      public void testFromFluentFuture() {
        FluentFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
      public void testFromFluentFuturePassingAsNonFluent() {
        ListenableFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  6. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  9. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  10. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
Back to top