Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 78 for Daniel (0.17 sec)

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

          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
        @Override
        public final boolean cancel(boolean mayInterruptIfRunning) {
          return super.cancel(mayInterruptIfRunning);
        }
      }
    
      FluentFuture() {}
    
      /**
       * Converts the given {@code ListenableFuture} to an equivalent {@code FluentFuture}.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 11 19:08:44 GMT 2023
    - 18.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/SettableFuture.java

    /**
     * A {@link ListenableFuture} whose result can be set by a {@link #set(Object)}, {@link
     * #setException(Throwable)} or {@link #setFuture(ListenableFuture)} call. It can also, like any
     * other {@code Future}, be {@linkplain #cancel cancelled}.
     *
     * <p>{@code SettableFuture} is the recommended {@code ListenableFuture} implementation when your
     * task cannot be implemented with {@link ListeningExecutorService}, the various {@link Futures}
    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. android/guava/src/com/google/common/util/concurrent/CollectionFuture.java

      /*
       * We access this field racily but safely. For discussion of a similar situation, see the comments
       * on the fields of TimeoutFuture. This field is slightly different from the fields discussed
       * there: cancel() never reads this field, only writes to it. That makes the race here completely
       * harmless, rather than just 99.99% harmless.
       */
      @CheckForNull @LazyInit private List<@Nullable Present<V>> values;
    
      CollectionFuture(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

                assertFalse(called);
                assertThat(t).isInstanceOf(CancellationException.class);
                called = true;
              }
            };
        addCallback(f, callback, directExecutor());
        f.cancel(true);
      }
    
      public void testThrowErrorFromGet() {
        Error error = new AssertionError("ASSERT!");
        ListenableFuture<String> f = UncheckedThrowingFuture.throwingError(error);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 6.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

        }
      }
    
      private static final class RuntimeExceptionThrowingFuture<V> implements Future<V> {
        final CountDownLatch allowGetToComplete = new CountDownLatch(1);
    
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          throw new AssertionFailedError();
        }
    
        @Override
        public V get() throws InterruptedException {
          /*
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 9.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/base/Ascii.java

       * structure is not necessarily related to the processing format.
       *
       * @since 8.0
       */
      public static final byte ETB = 23;
    
      /**
       * Cancel: A control character used to indicate that the data with which it is sent is in error or
       * is to be disregarded.
       *
       * @since 8.0
       */
      public static final byte CAN = 24;
    
      /**
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Jul 19 15:43:07 GMT 2021
    - 21.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        try {
          future.get(timeoutMillis, MILLISECONDS);
          shouldThrow();
        } catch (TimeoutException success) {
        } catch (Exception e) {
          threadUnexpectedException(e);
        } finally {
          future.cancel(true);
        }
        assertTrue(millisElapsedSince(startTime) >= timeoutMillis);
      }
    
      /** Fails with message "should throw exception". */
      public void shouldThrow() {
        fail("Should throw exception");
      }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        assertFailed(future, cause);
      }
    
      public void testCanceled() throws Exception {
        assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, false);
      }
    
      public void testInterrupted() throws Exception {
        assertThat(future.cancel(true /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, true);
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        async.setFuture(inner);
        async.cancel(false);
        assertTrue(inner.isCancelled());
        assertFalse(inner.wasInterrupted());
        assertThrows(CancellationException.class, () -> inner.get());
      }
    
      public void testCancel_beforeSet() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
        async.cancel(true);
        assertFalse(async.set(42));
      }
    
    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)
  10. android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        async.setFuture(inner);
        async.cancel(false);
        assertTrue(inner.isCancelled());
        assertFalse(inner.wasInterrupted());
        assertThrows(CancellationException.class, () -> inner.get());
      }
    
      public void testCancel_beforeSet() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
        async.cancel(true);
        assertFalse(async.set(42));
      }
    
    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)
Back to top