Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for setFuture (0.17 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java

           * succeeded.
           */
          set(uncheckedCastNullableTToT(sourceResult));
          return;
        }
    
        if (!isInstanceOfThrowableClass(throwable, localExceptionType)) {
          setFuture(localInputFuture);
          // TODO(cpovirk): Test that fallback is not run in this case.
          return;
        }
    
        @SuppressWarnings("unchecked") // verified safe by isInstanceOfThrowableClass
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/SettableFuture.java

      @Override
      public boolean setException(Throwable throwable) {
        return super.setException(throwable);
      }
    
      @CanIgnoreReturnValue
      @Override
      public boolean setFuture(ListenableFuture<? extends V> future) {
        return super.setFuture(future);
      }
    
      private SettableFuture() {}
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Oct 01 17:18:04 GMT 2021
    - 2.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        SettableFuture<String> nested = SettableFuture.create();
        assertTrue(future.setFuture(nested));
        // Later attempts to set the future should return false.
        assertFalse(future.set("x"));
        assertFalse(future.setException(new Exception("bar")));
        assertFalse(future.setFuture(SettableFuture.<String>create()));
        // Check that the future has been set properly.
        assertFalse(future.isDone());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.3K bytes
    - Viewed (1)
  4. android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        SettableFuture<String> nested = SettableFuture.create();
        assertTrue(future.setFuture(nested));
        // Later attempts to set the future should return false.
        assertFalse(future.set("x"));
        assertFalse(future.setException(new Exception("bar")));
        assertFalse(future.setFuture(SettableFuture.<String>create()));
        // Check that the future has been set properly.
        assertFalse(future.isDone());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/UntrustedInputFutureTest.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.util.concurrent.AbstractFuture.TrustedFuture;
    
    /**
     * Tests for {@link AbstractFuture} that use a non-{@link TrustedFuture} for {@link
     * AbstractFuture#setFuture} calls.
     */
    @GwtCompatible
    public class UntrustedInputFutureTest extends AbstractAbstractFutureTest {
      @Override
      AbstractFuture<Integer> newDelegate() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Dec 16 19:54:45 GMT 2020
    - 1.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java

      }
    
      @Override
      public void run() {
        InterruptibleTask<?> localTask = task;
        if (localTask != null) {
          localTask.run();
        }
        /*
         * In the Async case, we may have called setFuture(pendingFuture), in which case afterDone()
         * won't have been called yet.
         */
        this.task = null;
      }
    
      @Override
      protected void afterDone() {
        super.afterDone();
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Oct 01 17:18:04 GMT 2021
    - 5.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/UntrustedInputFutureTest.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.util.concurrent.AbstractFuture.TrustedFuture;
    
    /**
     * Tests for {@link AbstractFuture} that use a non-{@link TrustedFuture} for {@link
     * AbstractFuture#setFuture} calls.
     */
    @GwtCompatible
    public class UntrustedInputFutureTest extends AbstractAbstractFutureTest {
      @Override
      AbstractFuture<Integer> newDelegate() {
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Wed Dec 16 19:54:45 GMT 2020
    - 1.2K bytes
    - Viewed (1)
  8. guava-tests/test/com/google/common/util/concurrent/TrustedInputFutureTest.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.util.concurrent.AbstractFuture.TrustedFuture;
    
    /**
     * Tests for {@link AbstractFuture} that use a {@link TrustedFuture} for {@link
     * AbstractFuture#setFuture} calls.
     */
    @GwtCompatible
    public class TrustedInputFutureTest extends AbstractAbstractFutureTest {
      @Override
      AbstractFuture<Integer> newDelegate() {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Dec 16 19:54:45 GMT 2020
    - 1.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/TrustedInputFutureTest.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.util.concurrent.AbstractFuture.TrustedFuture;
    
    /**
     * Tests for {@link AbstractFuture} that use a {@link TrustedFuture} for {@link
     * AbstractFuture#setFuture} calls.
     */
    @GwtCompatible
    public class TrustedInputFutureTest extends AbstractAbstractFutureTest {
      @Override
      AbstractFuture<Integer> newDelegate() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Dec 16 19:54:45 GMT 2020
    - 1.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

                executor.execute(runnable);
              }
            };
        Future<?> future = newFutureInstance();
        future
            .getClass()
            .getMethod(
                "setFuture",
                future.getClass().getClassLoader().loadClass(ListenableFuture.class.getName()))
            .invoke(future, badFuture);
        CancellationException expected = assertThrows(CancellationException.class, () -> future.get());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
Back to top