Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 354 for Futures (0.04 seconds)

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

    import com.google.common.annotations.J2ktIncompatible;
    
    /**
     * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of
     * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function,
     * java.util.concurrent.Executor) Futures.catching} family of methods. Those versions have slightly
     * different signatures.
     */
    @GwtCompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

    import com.google.common.annotations.J2ktIncompatible;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.Future;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Unit tests for {@link Futures#getUnchecked(Future)}. */
    @GwtCompatible
    @NullUnmarked
    public class FuturesGetUncheckedTest extends TestCase {
      public void testGetUnchecked_success() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

    import com.google.common.annotations.J2ktIncompatible;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.Future;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Unit tests for {@link Futures#getUnchecked(Future)}. */
    @GwtCompatible
    @NullUnmarked
    public class FuturesGetUncheckedTest extends TestCase {
      public void testGetUnchecked_success() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  4. guava/src/com/google/common/util/concurrent/Partially.java

     * {@code GwtIncompatible}. This is more accurate for {@link Futures#catching}, which is available
     * under GWT but with a slightly different signature.
     *
     * <p>We can't use {@code PartiallyGwtIncompatible} because then the GWT compiler wouldn't recognize
     * it as a {@code GwtIncompatible} annotation. And for {@code Futures.catching}, we need the GWT
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * completing the returned {@code Future}.)
       *
       * <p>The returned {@code Future} attempts to keep its cancellation state in sync with that of the
       * input future and that of the future returned by the chain function. That is, if the returned
       * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the
       * other two is cancelled, the returned {@code Future} will receive a callback in which it will
    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)
  6. guava-tests/test/com/google/common/util/concurrent/FuturesTransformTest.java

    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.Futures.transform;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    
    import com.google.common.base.Function;
    import java.lang.reflect.UndeclaredThrowableException;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Unit tests for {@link Futures#transform(ListenableFuture, Function, Executor)}.
     *
     * @author Nishant Thakkar
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 2K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.Futures.transformAsync;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.Futures.transformAsync;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  9. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization.java

          Executor executor) {
        return (FluentFuture<V>) Futures.catching(this, exceptionType, fallback, executor);
      }
    
      public final FluentFuture<V> catchingAsync(
          Class<Throwable> exceptionType,
          AsyncFunction<? super Throwable, ? extends V> fallback,
          Executor executor) {
        return (FluentFuture<V>) Futures.catchingAsync(this, exceptionType, fallback, executor);
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  10. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        try {
          sourceResult = getDone(localInputFuture);
        } catch (CancellationException e) {
          // TODO(user): verify future behavior - unify logic with getFutureValue in AbstractFuture. This
          // code should be unreachable with correctly implemented Futures.
          // Cancel this future and return.
          // At this point, inputFuture is cancelled and outputFuture doesn't exist, so the value of
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
Back to Top