Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for SetFuture (0.09 sec)

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

        assertCancelled(future, true);
      }
    
      public void testSetFuturePending() throws Exception {
        assertThat(future.setFuture(delegate)).isTrue();
        assertSetAsynchronously(future);
      }
    
      public void testSetFutureThenCancel() throws Exception {
        assertThat(future.setFuture(delegate)).isTrue();
        assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, false);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  2. 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());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        assertCancelled(future, true);
      }
    
      public void testSetFuturePending() throws Exception {
        assertThat(future.setFuture(delegate)).isTrue();
        assertSetAsynchronously(future);
      }
    
      public void testSetFutureThenCancel() throws Exception {
        assertThat(future.setFuture(delegate)).isTrue();
        assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, false);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  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());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

            if (task instanceof SetFuture) {
              SetFuture<?> setFuture = (SetFuture<?>) task;
              // We unwind setFuture specifically to avoid StackOverflowErrors in the case of long
              // chains of SetFutures
              // Handling this special case is important because there is no way to pass an executor to
              // setFuture, so a user couldn't break the chain by doing this themselves.  It is also
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractFuture.java

            if (task instanceof SetFuture) {
              SetFuture<?> setFuture = (SetFuture<?>) task;
              // We unwind setFuture specifically to avoid StackOverflowErrors in the case of long
              // chains of SetFutures
              // Handling this special case is important because there is no way to pass an executor to
              // setFuture, so a user couldn't break the chain by doing this themselves.  It is also
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            // cancellation can interleave in 3 ways
            // 1. prior to setFuture
            // 2. after setFuture before set() on the future assigned
            // 3. after setFuture and set() are called but before the listener completes.
            if (!setFutureSetSuccess.get() || !setFutureCompletionSuccess.get()) {
              // If setFuture fails or set on the future fails then it must be because that future was
              // cancelled
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            // cancellation can interleave in 3 ways
            // 1. prior to setFuture
            // 2. after setFuture before set() on the future assigned
            // 3. after setFuture and set() are called but before the listener completes.
            if (!setFutureSetSuccess.get() || !setFutureCompletionSuccess.get()) {
              // If setFuture fails or set on the future fails then it must be because that future was
              // cancelled
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          return;
        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
              setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting
          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. 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
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 8.7K bytes
    - Viewed (0)
Back to top