Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 13 of 13 for transformAsync (0.45 seconds)

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

       *     input's failure (if not)
       */
      public final <T extends @Nullable Object> FluentFuture<T> transformAsync(
          AsyncFunction<? super V, T> function, Executor executor) {
        return (FluentFuture<T>) Futures.transformAsync(this, function, executor);
      }
    
      /**
       * Returns a new {@code Future} whose result is derived from the result of this {@code Future}. If
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/Futures.java

       * Example usage:
       *
       * {@snippet :
       * ListenableFuture<RowKey> rowKeyFuture = indexService.lookUp(query);
       * ListenableFuture<QueryResult> queryFuture =
       *     transformAsync(rowKeyFuture, dataService::readFuture, executor);
       * }
       *
       * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

              // setFuture, so a user couldn't break the chain by doing this themselves.  It is also
              // potentially common if someone writes a recursive Futures.transformAsync transformer.
              future = setFuture.owner;
              if (future.value() == setFuture) {
                Object valueToSet = getFutureValue(setFuture.future);
                if (casValue(future, setFuture, valueToSet)) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
Back to Top