Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for transformAsync (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

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

            };
        return derive(future.transformAsync(applyFunction, executor));
      }
    
      /**
       * Returns an {@link AsyncClosingFunction} that applies an {@link AsyncFunction} to an input,
       * ignoring the DeferredCloser and returning a {@code ClosingFuture} derived from the returned
       * {@link ListenableFuture}.
       *
       * <p>Use this method to pass a transformation to {@link #transformAsync(AsyncClosingFunction,
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 13:51:27 GMT 2025
    - 96.9K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/AsyncFunction.java

    import java.util.concurrent.Future;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Transforms a value, possibly asynchronously. For an example usage and more information, see
     * {@link Futures#transformAsync(ListenableFuture, AsyncFunction, Executor)}.
     *
     * @author Chris Povirk
     * @since 11.0
     */
    @GwtCompatible
    public interface AsyncFunction<I extends @Nullable Object, O extends @Nullable Object> {
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  3. 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 Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  4. 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 Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 64.3K bytes
    - Click Count (0)
Back to Top