Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for FluentFuture (0.07 sec)

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

          return super.cancel(mayInterruptIfRunning);
        }
      }
    
      FluentFuture() {}
    
      /**
       * Converts the given {@code ListenableFuture} to an equivalent {@code FluentFuture}.
       *
       * <p>If the given {@code ListenableFuture} is already a {@code FluentFuture}, it is returned
       * directly. If not, it is wrapped in a {@code FluentFuture} that delegates all calls to the
       * original {@code ListenableFuture}.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

    /**
     * Tests for {@link FluentFuture}. The tests cover only the basics for the API. The actual logic is
     * tested in {@link FuturesTest}.
     */
    @NullMarked
    @GwtCompatible
    public class FluentFutureTest extends TestCase {
      @SuppressWarnings({"deprecation", "InlineMeInliner"}) // test of a deprecated method
      public void testFromFluentFuture() {
        FluentFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

      private final CloseableList closeables;
      private final FluentFuture<V> future;
    
      private ClosingFuture(ListenableFuture<V> future) {
        this(future, new CloseableList());
      }
    
      private ClosingFuture(ListenableFuture<V> future, CloseableList closeables) {
        this.future = FluentFuture.from(future);
        this.closeables = closeables;
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java

     *
     * <p>This should be used in preference to {@link ListenableFutureTask} when possible for
     * performance reasons.
     */
    @GwtCompatible
    class TrustedListenableFutureTask<V extends @Nullable Object> extends FluentFuture.TrustedFuture<V>
        implements RunnableFuture<V> {
    
      static <V extends @Nullable Object> TrustedListenableFutureTask<V> create(
          AsyncCallable<V> callable) {
        return new TrustedListenableFutureTask<>(callable);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ClosingFuture.java

      private final CloseableList closeables;
      private final FluentFuture<V> future;
    
      private ClosingFuture(ListenableFuture<V> future) {
        this(future, new CloseableList());
      }
    
      private ClosingFuture(ListenableFuture<V> future, CloseableList closeables) {
        this.future = FluentFuture.from(future);
        this.closeables = closeables;
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Futures.java

         * should throw IllegalStateException only when they use static state.
         *
         * Why do we deviate here? The answer: We want for fluentFuture.getDone() to throw the same
         * exception as Futures.getDone(fluentFuture).
         */
        checkState(future.isDone(), "Future was expected to be done: %s", future);
        return getUninterruptibly(future);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
Back to top