Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Combiner2 (0.05 sec)

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

       */
      public static <V1 extends @Nullable Object, V2 extends @Nullable Object>
          Combiner2<V1, V2> whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2) {
        return new Combiner2<>(future1, future2);
      }
    
      /**
       * Starts specifying how to combine three {@link ClosingFuture}s into a single pipeline, assuming
    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/src/com/google/common/util/concurrent/ClosingFuture.java

       */
      public static <V1 extends @Nullable Object, V2 extends @Nullable Object>
          Combiner2<V1, V2> whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2) {
        return new Combiner2<>(future1, future2);
      }
    
      /**
       * Starts specifying how to combine three {@link ClosingFuture}s into a single pipeline, assuming
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

    import com.google.common.util.concurrent.ClosingFuture.Combiner;
    import com.google.common.util.concurrent.ClosingFuture.Combiner.AsyncCombiningCallable;
    import com.google.common.util.concurrent.ClosingFuture.Combiner.CombiningCallable;
    import com.google.common.util.concurrent.ClosingFuture.Combiner2.AsyncClosingFunction2;
    import com.google.common.util.concurrent.ClosingFuture.Combiner2.ClosingFunction2;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Futures.java

            Callable<C> combiner, Executor executor) {
          return new CombinedFuture<>(futures, allMustSucceed, executor, combiner);
        }
    
        /**
         * Creates the {@link ListenableFuture} which will return the result of running {@code combiner}
         * when all Futures complete. {@code combiner} will run using {@code executor}.
         *
    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-testlib/src/com/google/common/testing/CollectorTester.java

            A accum = collector.supplier().get();
            for (T input : inputs) {
              A newAccum = collector.supplier().get();
              collector.accumulator().accept(newAccum, input);
              accum = collector.combiner().apply(accum, newAccum);
            }
            return accum;
          }
        },
        /** Get one accumulator for each element and merge the accumulators right-to-left. */
        MERGE_RIGHT_ASSOCIATIVE {
          @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu May 15 21:47:56 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/testing/CollectorTester.java

            A accum = collector.supplier().get();
            for (T input : inputs) {
              A newAccum = collector.supplier().get();
              collector.accumulator().accept(newAccum, input);
              accum = collector.combiner().apply(accum, newAccum);
            }
            return accum;
          }
        },
        /** Get one accumulator for each element and merge the accumulators right-to-left. */
        MERGE_RIGHT_ASSOCIATIVE {
          @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu May 15 21:47:56 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/TableCollectors.java

          }
        }
    
        /*
         * While the current implementation returns `this`, that's not something we mean to guarantee.
         * Anyway, the purpose of this method is to implement a BinaryOperator combiner for a Collector,
         * so its return value will get used naturally.
         */
        @SuppressWarnings("CanIgnoreReturnValueSuggester")
        ImmutableTableCollectorState<R, C, V> combine(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Feb 11 19:03:19 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/TableCollectors.java

          }
        }
    
        /*
         * While the current implementation returns `this`, that's not something we mean to guarantee.
         * Anyway, the purpose of this method is to implement a BinaryOperator combiner for a Collector,
         * so its return value will get used naturally.
         */
        @SuppressWarnings("CanIgnoreReturnValueSuggester")
        ImmutableTableCollectorState<R, C, V> combine(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 16:07:06 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/TopKSelector.java

        buffer[j] = tmp;
      }
    
      /*
       * While the current implementation returns `this`, that's not something we mean to guarantee.
       * Anyway, the purpose of this method is to implement a BinaryOperator combiner for a Collector,
       * so its return value will get used naturally.
       */
      @SuppressWarnings("CanIgnoreReturnValueSuggester")
      TopKSelector<T> combine(TopKSelector<T> other) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 31 13:15:26 UTC 2025
    - 11.4K bytes
    - Viewed (0)
Back to top