Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for AsyncFunction (0.04 sec)

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

          Class<X> exceptionType, AsyncClosingFunction<? super X, W> fallback, Executor executor) {
        checkNotNull(fallback);
        AsyncFunction<X, W> asyncFunction =
            new AsyncFunction<X, W>() {
              @Override
              public ListenableFuture<W> apply(X exception) throws Exception {
                return closeables.applyAsyncClosingFunction(fallback, exception);
              }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

        FluentFuture<?> f =
            FluentFuture.from(immediateFailedFuture(new CustomRuntimeException()))
                .catchingAsync(
                    Throwable.class,
                    new AsyncFunction<Throwable, Class<?>>() {
                      @Override
                      public ListenableFuture<Class<?>> apply(Throwable input) {
                        return Futures.<Class<?>>immediateFuture(input.getClass());
    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/FluentFuture.java

      /**
       * Returns a {@code Future} whose result is taken from this {@code Future} or, if this {@code
       * Future} fails with the given {@code exceptionType}, from the result provided by the {@code
       * fallback}. {@link AsyncFunction#apply} is not invoked until the primary input has failed, so if
       * the primary input succeeds, it is never invoked. If, during the invocation of {@code fallback},
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Futures.java

       * Returns a {@code Future} whose result is taken from the given primary {@code input} or, if the
       * primary input fails with the given {@code exceptionType}, from the result provided by the
       * {@code fallback}. {@link AsyncFunction#apply} is not invoked until the primary input has
       * failed, so if the primary input succeeds, it is never invoked. If, during the invocation of
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ClosingFuture.java

          Class<X> exceptionType, AsyncClosingFunction<? super X, W> fallback, Executor executor) {
        checkNotNull(fallback);
        AsyncFunction<X, W> asyncFunction =
            new AsyncFunction<X, W>() {
              @Override
              public ListenableFuture<W> apply(X exception) throws Exception {
                return closeables.applyAsyncClosingFunction(fallback, exception);
              }
    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-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

                      }
                    },
                    executor)
                .transformAsync(
                    withoutCloser(
                        new AsyncFunction<TestCloseable, String>() {
                          @Override
                          public ListenableFuture<String> apply(TestCloseable v) throws Exception {
                            assertThat(v).isSameInstanceAs(closeable1);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
Back to top