Package io.foldright.cffu2

Class CfIterableUtils

java.lang.Object

io.foldright.cffu2.CfIterableUtils

public final class CfIterableUtils
extends Object

This utility class provides Iterable-based variants (including Collection, List, etc.) of same-named varargs methods from CompletableFutureUtils. These methods handle multiple actions and CompletableFutures with the same type (aka. homogeneous).

While CfTupleUtils uses strongly typed tuples for handling different types of actions and CompletableFutures (aka. heterogeneous), this class and CompletableFutureUtils work with homogeneous types, offering a flexible approach for handling collections of actions and CompletableFutures of the same type.

Author:

Eric Lin (linqinghua4 at gmail dot com), Jerry Lee (oldratlee at gmail dot com)

See Also:

• CompletableFutureUtils
• CfParallelUtils
• CfTupleUtils

Method Summary

Modifier and Type	Method	Description
static CompletableFuture<Void>	allFailFastOf(Iterable<? extends CompletionStage<?>> cfs)	Iterable variant of CompletableFutureUtils.allFailFastOf(CompletionStage[]).
static CompletableFuture<Void>	allOf(Iterable<? extends CompletionStage<?>> cfs)	Iterable variant of CompletableFutureUtils.allOf(CompletionStage[]).
static <T> CompletableFuture<List<T>>	allResultsFailFastOf(Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CompletableFutureUtils.allResultsFailFastOf(CompletionStage[]).
static <T> CompletableFuture<List<T>>	allResultsOf(Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CompletableFutureUtils.allResultsOf(java.util.concurrent.CompletionStage<? extends T>...).
static <T> CompletableFuture<List<T>>	allSuccessResultsOf(T valueIfFailed, Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CompletableFutureUtils.allSuccessResultsOf(Object, CompletionStage[]).
static <T> CompletableFuture<T>	anyOf(Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CompletableFutureUtils.anyOf(CompletionStage[]).
static <T> CompletableFuture<T>	anySuccessOf(Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CompletableFutureUtils.anySuccessOf(CompletionStage[]).
static <T> CompletableFuture<List<T>>	mostSuccessResultsOf(T valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CompletableFutureUtils.mostSuccessResultsOf(Object, long, TimeUnit, CompletionStage[]).
static <T> CompletableFuture<List<T>>	mostSuccessResultsOf(T valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends CompletionStage<? extends T>> cfs, Executor executorWhenTimeout)	Iterable variant of CompletableFutureUtils.mostSuccessResultsOf(Executor, Object, long, TimeUnit, CompletionStage[]).
static CompletableFuture<Void>	mRunAnyAsync(Iterable<? extends Runnable> actions)	Iterable variant of CompletableFutureUtils.mRunAnyAsync(Runnable...).
static CompletableFuture<Void>	mRunAnyAsync(Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CompletableFutureUtils.mRunAnyAsync(Executor, Runnable...).
static CompletableFuture<Void>	mRunAnySuccessAsync(Iterable<? extends Runnable> actions)	Iterable variant of CompletableFutureUtils.mRunAnySuccessAsync(Runnable...).
static CompletableFuture<Void>	mRunAnySuccessAsync(Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CompletableFutureUtils.mRunAnySuccessAsync(Executor, Runnable...).
static CompletableFuture<Void>	mRunAsync(Iterable<? extends Runnable> actions)	Iterable variant of CompletableFutureUtils.mRunAsync(Runnable...).
static CompletableFuture<Void>	mRunAsync(Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CompletableFutureUtils.mRunAsync(Executor, Runnable...).
static CompletableFuture<Void>	mRunFailFastAsync(Iterable<? extends Runnable> actions)	Iterable variant of CompletableFutureUtils.mRunFailFastAsync(Runnable...).
static CompletableFuture<Void>	mRunFailFastAsync(Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CompletableFutureUtils.mRunFailFastAsync(Executor, Runnable...).
static <T> CompletableFuture<List<T>>	mSupplyAllSuccessAsync(T valueIfFailed, Iterable<? extends Supplier<? extends T>> suppliers)	Iterable variant of CompletableFutureUtils.mSupplyAllSuccessAsync(Object, Supplier[]).
static <T> CompletableFuture<List<T>>	mSupplyAllSuccessAsync(T valueIfFailed, Iterable<? extends Supplier<? extends T>> suppliers, Executor executor)	Iterable variant of CompletableFutureUtils.mSupplyAllSuccessAsync(Executor, Object, Supplier[]).
static <T> CompletableFuture<T>	mSupplyAnyAsync(Iterable<? extends Supplier<? extends T>> suppliers)	Iterable variant of CompletableFutureUtils.mSupplyAnyAsync(Supplier[]).
static <T> CompletableFuture<T>	mSupplyAnyAsync(Iterable<? extends Supplier<? extends T>> suppliers, Executor executor)	Iterable variant of CompletableFutureUtils.mSupplyAnyAsync(Executor, Supplier[]).
static <T> CompletableFuture<T>	mSupplyAnySuccessAsync(Iterable<? extends Supplier<? extends T>> suppliers)	Iterable variant of CompletableFutureUtils.mSupplyAnySuccessAsync(Supplier[]).
static <T> CompletableFuture<T>	mSupplyAnySuccessAsync(Iterable<? extends Supplier<? extends T>> suppliers, Executor executor)	Iterable variant of CompletableFutureUtils.mSupplyAnySuccessAsync(Executor, Supplier[]).
static <T> CompletableFuture<List<T>>	mSupplyAsync(Iterable<? extends Supplier<? extends T>> suppliers)	Iterable variant of CompletableFutureUtils.mSupplyAsync(Supplier[]).
static <T> CompletableFuture<List<T>>	mSupplyAsync(Iterable<? extends Supplier<? extends T>> suppliers, Executor executor)	Iterable variant of CompletableFutureUtils.mSupplyAsync(Executor, Supplier[]).
static <T> CompletableFuture<List<T>>	mSupplyFailFastAsync(Iterable<? extends Supplier<? extends T>> suppliers)	Iterable variant of CompletableFutureUtils.mSupplyFailFastAsync(Supplier[]).
static <T> CompletableFuture<List<T>>	mSupplyFailFastAsync(Iterable<? extends Supplier<? extends T>> suppliers, Executor executor)	Iterable variant of CompletableFutureUtils.mSupplyFailFastAsync(Executor, Supplier[]).
static <T> CompletableFuture<List<T>>	mSupplyMostSuccessAsync(T valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends Supplier<? extends T>> suppliers)	Iterable variant of CompletableFutureUtils.mSupplyMostSuccessAsync(Object, long, TimeUnit, Supplier[]).
static <T> CompletableFuture<List<T>>	mSupplyMostSuccessAsync(T valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends Supplier<? extends T>> suppliers, Executor executor)	Iterable variant of CompletableFutureUtils.mSupplyMostSuccessAsync(Executor, Object, long, TimeUnit, Supplier[]).
static <T> CompletableFuture<Void>	thenMAcceptAnyAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Consumer<? super T>> actions)	Iterable variant of CompletableFutureUtils.thenMAcceptAnyAsync(CompletableFuture, Consumer[]).
static <T> CompletableFuture<Void>	thenMAcceptAnyAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Consumer<? super T>> actions, Executor executor)	Iterable variant of CompletableFutureUtils.thenMAcceptAnyAsync(CompletableFuture, Executor, Consumer[]).
static <T> CompletableFuture<Void>	thenMAcceptAnySuccessAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Consumer<? super T>> actions)	Iterable variant of CompletableFutureUtils.thenMAcceptAnySuccessAsync(CompletableFuture, Consumer[]).
static <T> CompletableFuture<Void>	thenMAcceptAnySuccessAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Consumer<? super T>> actions, Executor executor)	Iterable variant of CompletableFutureUtils.thenMAcceptAnySuccessAsync(CompletableFuture, Executor, Consumer[]).
static <T> CompletableFuture<Void>	thenMAcceptAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Consumer<? super T>> actions)	Iterable variant of CompletableFutureUtils.thenMAcceptAsync(CompletableFuture, Consumer[]).
static <T> CompletableFuture<Void>	thenMAcceptAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Consumer<? super T>> actions, Executor executor)	Iterable variant of CompletableFutureUtils.thenMAcceptAsync(CompletableFuture, Executor, Consumer[]).
static <T> CompletableFuture<Void>	thenMAcceptFailFastAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Consumer<? super T>> actions)	Iterable variant of CompletableFutureUtils.thenMAcceptFailFastAsync(CompletableFuture, Consumer[]).
static <T> CompletableFuture<Void>	thenMAcceptFailFastAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Consumer<? super T>> actions, Executor executor)	Iterable variant of CompletableFutureUtils.thenMAcceptFailFastAsync(CompletableFuture, Executor, Consumer[]).
static <T, U> CompletableFuture<List<U>>	thenMApplyAllSuccessAsync(CompletableFuture<? extends T> cfThis, U valueIfFailed, Iterable<? extends Function<? super T,? extends U>> fns)	Iterable variant of CompletableFutureUtils.thenMApplyAllSuccessAsync(CompletableFuture, Object, Function[]).
static <T, U> CompletableFuture<List<U>>	thenMApplyAllSuccessAsync(CompletableFuture<? extends T> cfThis, U valueIfFailed, Iterable<? extends Function<? super T,? extends U>> fns, Executor executor)	Iterable variant of CompletableFutureUtils.thenMApplyAllSuccessAsync(CompletableFuture, Executor, Object, Function[]).
static <T, U> CompletableFuture<U>	thenMApplyAnyAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Function<? super T,? extends U>> fns)	Iterable variant of CompletableFutureUtils.thenMApplyAnyAsync(CompletableFuture, Function[]).
static <T, U> CompletableFuture<U>	thenMApplyAnyAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Function<? super T,? extends U>> fns, Executor executor)	Iterable variant of CompletableFutureUtils.thenMApplyAnyAsync(CompletableFuture, Executor, Function[]).
static <T, U> CompletableFuture<U>	thenMApplyAnySuccessAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Function<? super T,? extends U>> fns)	Iterable variant of CompletableFutureUtils.thenMApplyAnySuccessAsync(CompletableFuture, Function[]).
static <T, U> CompletableFuture<U>	thenMApplyAnySuccessAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Function<? super T,? extends U>> fns, Executor executor)	Iterable variant of CompletableFutureUtils.thenMApplyAnySuccessAsync(CompletableFuture, Executor, Function[]).
static <T, U> CompletableFuture<List<U>>	thenMApplyAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Function<? super T,? extends U>> fns)	Iterable variant of CompletableFutureUtils.thenMApplyAsync(CompletableFuture, Function[]).
static <T, U> CompletableFuture<List<U>>	thenMApplyAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Function<? super T,? extends U>> fns, Executor executor)	Iterable variant of CompletableFutureUtils.thenMApplyAsync(CompletableFuture, Executor, Function[]).
static <T, U> CompletableFuture<List<U>>	thenMApplyFailFastAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Function<? super T,? extends U>> fns)	Iterable variant of CompletableFutureUtils.thenMApplyFailFastAsync(CompletableFuture, Function[]).
static <T, U> CompletableFuture<List<U>>	thenMApplyFailFastAsync(CompletableFuture<? extends T> cfThis, Iterable<? extends Function<? super T,? extends U>> fns, Executor executor)	Iterable variant of CompletableFutureUtils.thenMApplyFailFastAsync(CompletableFuture, Executor, Function[]).
static <T, U> CompletableFuture<List<U>>	thenMApplyMostSuccessAsync(CompletableFuture<? extends T> cfThis, U valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends Function<? super T,? extends U>> fns)	Iterable variant of CompletableFutureUtils.thenMApplyMostSuccessAsync(CompletableFuture, Object, long, TimeUnit, Function[]).
static <T, U> CompletableFuture<List<U>>	thenMApplyMostSuccessAsync(CompletableFuture<? extends T> cfThis, U valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends Function<? super T,? extends U>> fns, Executor executor)	Iterable variant of CompletableFutureUtils.thenMApplyMostSuccessAsync(CompletableFuture, Executor, Object, long, TimeUnit, Function[]).
static CompletableFuture<Void>	thenMRunAnyAsync(CompletableFuture<?> cfThis, Iterable<? extends Runnable> actions)	Iterable variant of CompletableFutureUtils.thenMRunAnyAsync(CompletableFuture, Runnable...).
static CompletableFuture<Void>	thenMRunAnyAsync(CompletableFuture<?> cfThis, Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CompletableFutureUtils.thenMRunAnyAsync(CompletableFuture, Executor, Runnable...).
static CompletableFuture<Void>	thenMRunAnySuccessAsync(CompletableFuture<?> cfThis, Iterable<? extends Runnable> actions)	Iterable variant of CompletableFutureUtils.thenMRunAnySuccessAsync(CompletableFuture, Runnable...).
static CompletableFuture<Void>	thenMRunAnySuccessAsync(CompletableFuture<?> cfThis, Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CompletableFutureUtils.thenMRunAnySuccessAsync(CompletableFuture, Executor, Runnable...).
static CompletableFuture<Void>	thenMRunAsync(CompletableFuture<?> cfThis, Iterable<? extends Runnable> actions)	Iterable variant of CompletableFutureUtils.thenMRunAsync(CompletableFuture, Runnable...).
static CompletableFuture<Void>	thenMRunAsync(CompletableFuture<?> cfThis, Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CompletableFutureUtils.thenMRunAsync(CompletableFuture, Executor, Runnable...).
static CompletableFuture<Void>	thenMRunFailFastAsync(CompletableFuture<?> cfThis, Iterable<? extends Runnable> actions)	Iterable variant of CompletableFutureUtils.thenMRunFailFastAsync(CompletableFuture, Runnable...).
static CompletableFuture<Void>	thenMRunFailFastAsync(CompletableFuture<?> cfThis, Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CompletableFutureUtils.thenMRunFailFastAsync(CompletableFuture, Executor, Runnable...).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

mSupplyFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<List<T>> mSupplyFailFastAsync(Iterable<? extends Supplier<? extends T>> suppliers)

Iterable variant of CompletableFutureUtils.mSupplyFailFastAsync(Supplier[]).

mSupplyFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<List<T>> mSupplyFailFastAsync(Iterable<? extends Supplier<? extends T>> suppliers,
 Executor executor)

Iterable variant of CompletableFutureUtils.mSupplyFailFastAsync(Executor, Supplier[]).

mSupplyAllSuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<List<T>> mSupplyAllSuccessAsync(@Nullable
 T valueIfFailed,
 Iterable<? extends Supplier<? extends T>> suppliers)

Iterable variant of CompletableFutureUtils.mSupplyAllSuccessAsync(Object, Supplier[]).

mSupplyAllSuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<List<T>> mSupplyAllSuccessAsync(@Nullable
 T valueIfFailed,
 Iterable<? extends Supplier<? extends T>> suppliers,
 Executor executor)

Iterable variant of CompletableFutureUtils.mSupplyAllSuccessAsync(Executor, Object, Supplier[]).

mSupplyMostSuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<List<T>> mSupplyMostSuccessAsync(@Nullable
 T valueIfNotSuccess,
 long timeout,
 TimeUnit unit,
 Iterable<? extends Supplier<? extends T>> suppliers)

Iterable variant of CompletableFutureUtils.mSupplyMostSuccessAsync(Object, long, TimeUnit, Supplier[]).

mSupplyMostSuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<List<T>> mSupplyMostSuccessAsync(@Nullable
 T valueIfNotSuccess,
 long timeout,
 TimeUnit unit,
 Iterable<? extends Supplier<? extends T>> suppliers,
 Executor executor)

Iterable variant of CompletableFutureUtils.mSupplyMostSuccessAsync(Executor, Object, long, TimeUnit, Supplier[]).

mSupplyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<List<T>> mSupplyAsync(Iterable<? extends Supplier<? extends T>> suppliers)

Iterable variant of CompletableFutureUtils.mSupplyAsync(Supplier[]).

mSupplyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<List<T>> mSupplyAsync(Iterable<? extends Supplier<? extends T>> suppliers,
 Executor executor)

Iterable variant of CompletableFutureUtils.mSupplyAsync(Executor, Supplier[]).

mSupplyAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<T> mSupplyAnySuccessAsync(Iterable<? extends Supplier<? extends T>> suppliers)

Iterable variant of CompletableFutureUtils.mSupplyAnySuccessAsync(Supplier[]).

mSupplyAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<T> mSupplyAnySuccessAsync(Iterable<? extends Supplier<? extends T>> suppliers,
 Executor executor)

Iterable variant of CompletableFutureUtils.mSupplyAnySuccessAsync(Executor, Supplier[]).

mSupplyAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<T> mSupplyAnyAsync(Iterable<? extends Supplier<? extends T>> suppliers)

Iterable variant of CompletableFutureUtils.mSupplyAnyAsync(Supplier[]).

mSupplyAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static <T> CompletableFuture<T> mSupplyAnyAsync(Iterable<? extends Supplier<? extends T>> suppliers,
 Executor executor)

Iterable variant of CompletableFutureUtils.mSupplyAnyAsync(Executor, Supplier[]).

mRunFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static CompletableFuture<Void> mRunFailFastAsync(Iterable<? extends Runnable> actions)

Iterable variant of CompletableFutureUtils.mRunFailFastAsync(Runnable...).

mRunFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static CompletableFuture<Void> mRunFailFastAsync(Iterable<? extends Runnable> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.mRunFailFastAsync(Executor, Runnable...).

mRunAsync

public static CompletableFuture<Void> mRunAsync(Iterable<? extends Runnable> actions)

Iterable variant of CompletableFutureUtils.mRunAsync(Runnable...).

mRunAsync

public static CompletableFuture<Void> mRunAsync(Iterable<? extends Runnable> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.mRunAsync(Executor, Runnable...).

mRunAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static CompletableFuture<Void> mRunAnySuccessAsync(Iterable<? extends Runnable> actions)

Iterable variant of CompletableFutureUtils.mRunAnySuccessAsync(Runnable...).

mRunAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static CompletableFuture<Void> mRunAnySuccessAsync(Iterable<? extends Runnable> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.mRunAnySuccessAsync(Executor, Runnable...).

mRunAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static CompletableFuture<Void> mRunAnyAsync(Iterable<? extends Runnable> actions)

Iterable variant of CompletableFutureUtils.mRunAnyAsync(Runnable...).

mRunAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `mRunAsync`")
public static CompletableFuture<Void> mRunAnyAsync(Iterable<? extends Runnable> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.mRunAnyAsync(Executor, Runnable...).

allResultsFailFastOf

@Contract(pure=true)
public static <T> CompletableFuture<List<T>> allResultsFailFastOf(Iterable<? extends CompletionStage<? extends T>> cfs)

Iterable variant of CompletableFutureUtils.allResultsFailFastOf(CompletionStage[]).

allSuccessResultsOf

@Contract(pure=true)
public static <T> CompletableFuture<List<T>> allSuccessResultsOf(@Nullable
 T valueIfFailed,
 Iterable<? extends CompletionStage<? extends T>> cfs)

Iterable variant of CompletableFutureUtils.allSuccessResultsOf(Object, CompletionStage[]).

mostSuccessResultsOf

@Contract(pure=true)
public static <T> CompletableFuture<List<T>> mostSuccessResultsOf(@Nullable
 T valueIfNotSuccess,
 long timeout,
 TimeUnit unit,
 Iterable<? extends CompletionStage<? extends T>> cfs)

Iterable variant of CompletableFutureUtils.mostSuccessResultsOf(Object, long, TimeUnit, CompletionStage[]).

mostSuccessResultsOf

@Contract(pure=true)
public static <T> CompletableFuture<List<T>> mostSuccessResultsOf(@Nullable
 T valueIfNotSuccess,
 long timeout,
 TimeUnit unit,
 Iterable<? extends CompletionStage<? extends T>> cfs,
 Executor executorWhenTimeout)

Iterable variant of CompletableFutureUtils.mostSuccessResultsOf(Executor, Object, long, TimeUnit, CompletionStage[]).

allResultsOf

@Contract(pure=true)
public static <T> CompletableFuture<List<T>> allResultsOf(Iterable<? extends CompletionStage<? extends T>> cfs)

Iterable variant of CompletableFutureUtils.allResultsOf(java.util.concurrent.CompletionStage<? extends T>...).

allFailFastOf

@Contract(pure=true)
public static CompletableFuture<Void> allFailFastOf(Iterable<? extends CompletionStage<?>> cfs)

Iterable variant of CompletableFutureUtils.allFailFastOf(CompletionStage[]).

allOf

@Contract(pure=true)
public static CompletableFuture<Void> allOf(Iterable<? extends CompletionStage<?>> cfs)

Iterable variant of CompletableFutureUtils.allOf(CompletionStage[]).

anySuccessOf

@Contract(pure=true)
public static <T> CompletableFuture<T> anySuccessOf(Iterable<? extends CompletionStage<? extends T>> cfs)

Iterable variant of CompletableFutureUtils.anySuccessOf(CompletionStage[]).

anyOf

@Contract(pure=true)
public static <T> CompletableFuture<T> anyOf(Iterable<? extends CompletionStage<? extends T>> cfs)

Iterable variant of CompletableFutureUtils.anyOf(CompletionStage[]).

thenMApplyFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<List<U>> thenMApplyFailFastAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Function<? super T,? extends U>> fns)

Iterable variant of CompletableFutureUtils.thenMApplyFailFastAsync(CompletableFuture, Function[]).

thenMApplyFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<List<U>> thenMApplyFailFastAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Function<? super T,? extends U>> fns,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMApplyFailFastAsync(CompletableFuture, Executor, Function[]).

thenMApplyAllSuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<List<U>> thenMApplyAllSuccessAsync(CompletableFuture<? extends T> cfThis,
 @Nullable
 U valueIfFailed,
 Iterable<? extends Function<? super T,? extends U>> fns)

Iterable variant of CompletableFutureUtils.thenMApplyAllSuccessAsync(CompletableFuture, Object, Function[]).

thenMApplyAllSuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<List<U>> thenMApplyAllSuccessAsync(CompletableFuture<? extends T> cfThis,
 @Nullable
 U valueIfFailed,
 Iterable<? extends Function<? super T,? extends U>> fns,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMApplyAllSuccessAsync(CompletableFuture, Executor, Object, Function[]).

thenMApplyMostSuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<List<U>> thenMApplyMostSuccessAsync(CompletableFuture<? extends T> cfThis,
 @Nullable
 U valueIfNotSuccess,
 long timeout,
 TimeUnit unit,
 Iterable<? extends Function<? super T,? extends U>> fns)

Iterable variant of CompletableFutureUtils.thenMApplyMostSuccessAsync(CompletableFuture, Object, long, TimeUnit, Function[]).

thenMApplyMostSuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<List<U>> thenMApplyMostSuccessAsync(CompletableFuture<? extends T> cfThis,
 @Nullable
 U valueIfNotSuccess,
 long timeout,
 TimeUnit unit,
 Iterable<? extends Function<? super T,? extends U>> fns,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMApplyMostSuccessAsync(CompletableFuture, Executor, Object, long, TimeUnit, Function[]).

thenMApplyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<List<U>> thenMApplyAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Function<? super T,? extends U>> fns)

Iterable variant of CompletableFutureUtils.thenMApplyAsync(CompletableFuture, Function[]).

thenMApplyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<List<U>> thenMApplyAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Function<? super T,? extends U>> fns,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMApplyAsync(CompletableFuture, Executor, Function[]).

thenMApplyAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<U> thenMApplyAnySuccessAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Function<? super T,? extends U>> fns)

Iterable variant of CompletableFutureUtils.thenMApplyAnySuccessAsync(CompletableFuture, Function[]).

thenMApplyAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<U> thenMApplyAnySuccessAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Function<? super T,? extends U>> fns,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMApplyAnySuccessAsync(CompletableFuture, Executor, Function[]).

thenMApplyAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<U> thenMApplyAnyAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Function<? super T,? extends U>> fns)

Iterable variant of CompletableFutureUtils.thenMApplyAnyAsync(CompletableFuture, Function[]).

thenMApplyAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T,
U> CompletableFuture<U> thenMApplyAnyAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Function<? super T,? extends U>> fns,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMApplyAnyAsync(CompletableFuture, Executor, Function[]).

thenMAcceptFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T> CompletableFuture<Void> thenMAcceptFailFastAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Consumer<? super T>> actions)

Iterable variant of CompletableFutureUtils.thenMAcceptFailFastAsync(CompletableFuture, Consumer[]).

thenMAcceptFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T> CompletableFuture<Void> thenMAcceptFailFastAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Consumer<? super T>> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMAcceptFailFastAsync(CompletableFuture, Executor, Consumer[]).

thenMAcceptAsync

public static <T> CompletableFuture<Void> thenMAcceptAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Consumer<? super T>> actions)

Iterable variant of CompletableFutureUtils.thenMAcceptAsync(CompletableFuture, Consumer[]).

thenMAcceptAsync

public static <T> CompletableFuture<Void> thenMAcceptAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Consumer<? super T>> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMAcceptAsync(CompletableFuture, Executor, Consumer[]).

thenMAcceptAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T> CompletableFuture<Void> thenMAcceptAnySuccessAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Consumer<? super T>> actions)

Iterable variant of CompletableFutureUtils.thenMAcceptAnySuccessAsync(CompletableFuture, Consumer[]).

thenMAcceptAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T> CompletableFuture<Void> thenMAcceptAnySuccessAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Consumer<? super T>> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMAcceptAnySuccessAsync(CompletableFuture, Executor, Consumer[]).

thenMAcceptAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T> CompletableFuture<Void> thenMAcceptAnyAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Consumer<? super T>> actions)

Iterable variant of CompletableFutureUtils.thenMAcceptAnyAsync(CompletableFuture, Consumer[]).

thenMAcceptAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMAcceptAsync`")
public static <T> CompletableFuture<Void> thenMAcceptAnyAsync(CompletableFuture<? extends T> cfThis,
 Iterable<? extends Consumer<? super T>> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMAcceptAnyAsync(CompletableFuture, Executor, Consumer[]).

thenMRunFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMRunAsync`")
public static CompletableFuture<Void> thenMRunFailFastAsync(CompletableFuture<?> cfThis,
 Iterable<? extends Runnable> actions)

Iterable variant of CompletableFutureUtils.thenMRunFailFastAsync(CompletableFuture, Runnable...).

thenMRunFailFastAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMRunAsync`")
public static CompletableFuture<Void> thenMRunFailFastAsync(CompletableFuture<?> cfThis,
 Iterable<? extends Runnable> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMRunFailFastAsync(CompletableFuture, Executor, Runnable...).

thenMRunAsync

public static CompletableFuture<Void> thenMRunAsync(CompletableFuture<?> cfThis,
 Iterable<? extends Runnable> actions)

Iterable variant of CompletableFutureUtils.thenMRunAsync(CompletableFuture, Runnable...).

thenMRunAsync

public static CompletableFuture<Void> thenMRunAsync(CompletableFuture<?> cfThis,
 Iterable<? extends Runnable> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMRunAsync(CompletableFuture, Executor, Runnable...).

thenMRunAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMRunAsync`")
public static CompletableFuture<Void> thenMRunAnySuccessAsync(CompletableFuture<?> cfThis,
 Iterable<? extends Runnable> actions)

Iterable variant of CompletableFutureUtils.thenMRunAnySuccessAsync(CompletableFuture, Runnable...).

thenMRunAnySuccessAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMRunAsync`")
public static CompletableFuture<Void> thenMRunAnySuccessAsync(CompletableFuture<?> cfThis,
 Iterable<? extends Runnable> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMRunAnySuccessAsync(CompletableFuture, Executor, Runnable...).

thenMRunAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMRunAsync`")
public static CompletableFuture<Void> thenMRunAnyAsync(CompletableFuture<?> cfThis,
 Iterable<? extends Runnable> actions)

Iterable variant of CompletableFutureUtils.thenMRunAnyAsync(CompletableFuture, Runnable...).

thenMRunAnyAsync

@CheckReturnValue(explanation="should use the returned CompletableFuture; otherwise, prefer simple method `thenMRunAsync`")
public static CompletableFuture<Void> thenMRunAnyAsync(CompletableFuture<?> cfThis,
 Iterable<? extends Runnable> actions,
 Executor executor)

Iterable variant of CompletableFutureUtils.thenMRunAnyAsync(CompletableFuture, Executor, Runnable...).