Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,291 for futuna (0.53 sec)

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

       * completes. Cancelling the supplied future will also cancel the returned future, but cancelling
       * the returned future will have no effect on the supplied future.
       *
       * @since 15.0
       */
      public static <V extends @Nullable Object> ListenableFuture<V> nonCancellationPropagating(
          ListenableFuture<V> future) {
        if (future.isDone()) {
          return future;
        }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/FluentFuture.java

      }
    
      /**
       * Returns a new {@code Future} whose result is asynchronously derived from the result of this
       * {@code Future}. If the input {@code Future} fails, the returned {@code Future} fails with the
       * same exception (and the function is not invoked).
       *
       * <p>More precisely, the returned {@code Future} takes its result from a {@code Future} produced
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 11 19:08:44 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/Futures.java

       * completes. Cancelling the supplied future will also cancel the returned future, but cancelling
       * the returned future will have no effect on the supplied future.
       *
       * @since 15.0
       */
      public static <V extends @Nullable Object> ListenableFuture<V> nonCancellationPropagating(
          ListenableFuture<V> future) {
        if (future.isDone()) {
          return future;
        }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 64.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        future = service.scheduleAtFixedRate(runnable, 5, 5, TimeUnit.MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
        assertTrue(delegateFuture.isCancelled());
    
        delegateQueue.clear();
    
        future = service.scheduleWithFixedDelay(runnable, 5, 5, TimeUnit.MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 28.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

          @CheckForNull
              ImmutableCollection<? extends Future<? extends InputT>>
                  futuresIfNeedToCollectAtCompletion) {
        if (futuresIfNeedToCollectAtCompletion != null) {
          int i = 0;
          for (Future<? extends InputT> future : futuresIfNeedToCollectAtCompletion) {
            if (!future.isCancelled()) {
              collectValueFromNonCancelledFuture(i, future);
            }
            i++;
          }
        }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        future = service.scheduleAtFixedRate(runnable, 5, 5, TimeUnit.MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
        assertTrue(delegateFuture.isCancelled());
    
        delegateQueue.clear();
    
        future = service.scheduleWithFixedDelay(runnable, 5, 5, TimeUnit.MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 28.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    
        assertTrue(latch.await(5, TimeUnit.SECONDS));
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    
        assertEquals(expectedValue, future.get());
      }
    
      public void testCancelledFuture() throws InterruptedException, ExecutionException {
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        SettableFuture<String> future = SettableFuture.create();
        FutureTask<Boolean> interruptReporter = untimedInterruptReporter(future, false);
    
        runNInterruptsTest(times, future, interruptReporter);
      }
    
      private static void runTimedInterruptsTest(int times)
          throws InterruptedException, ExecutionException, TimeoutException {
        SettableFuture<String> future = SettableFuture.create();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

      /**
       * Sets the result of this {@code Future} to match the supplied input {@code Future} once the
       * supplied {@code Future} is done, unless this {@code Future} has already been cancelled or set
       * (including "set asynchronously," defined below).
       *
       * <p>If the supplied future is {@linkplain #isDone done} when this method is called and the call
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  10. guava/src/com/google/common/util/concurrent/AbstractFuture.java

      /**
       * Sets the result of this {@code Future} to match the supplied input {@code Future} once the
       * supplied {@code Future} is done, unless this {@code Future} has already been cancelled or set
       * (including "set asynchronously," defined below).
       *
       * <p>If the supplied future is {@linkplain #isDone done} when this method is called and the call
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
Back to top