Package io.foldright.cffu2

Class CffuFactory.IterableOps

java.lang.Object

io.foldright.cffu2.CffuFactory.IterableOps

Enclosing class:

CffuFactory

public final class CffuFactory.IterableOps
extends Object

The Iterable-based variants (including Collection, List, etc.) of same-named varargs methods from CffuFactory. These methods handle multiple actions and Futures with the same type (aka. homogeneous).

Method Summary

Modifier and Type	Method	Description
Cffu<Void>	allFailFastOf(Iterable<? extends CompletionStage<?>> cfs)	Iterable variant of CffuFactory.allFailFastOf(CompletionStage[]).
Cffu<Void>	allOf(Iterable<? extends CompletionStage<?>> cfs)	Iterable variant of CffuFactory.allOf(CompletionStage[]).
<T> MCffu<T,List<T>>	allResultsFailFastOf(Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CffuFactory.allResultsFailFastOf(CompletionStage[]).
<T> MCffu<T,List<T>>	allResultsOf(Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CffuFactory.allResultsOf(java.util.concurrent.CompletionStage<? extends T>...).
<T> MCffu<T,List<T>>	allSuccessResultsOf(T valueIfFailed, Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CffuFactory.allSuccessResultsOf(Object, CompletionStage[]).
<T> Cffu<T>	anyOf(Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CffuFactory.anyOf(CompletionStage[]).
<T> Cffu<T>	anySuccessOf(Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CffuFactory.anySuccessOf(CompletionStage[]).
<T> MCffu<T,List<T>>	mostSuccessResultsOf(T valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends CompletionStage<? extends T>> cfs)	Iterable variant of CffuFactory.mostSuccessResultsOf(Object, long, TimeUnit, CompletionStage[]).
Cffu<Void>	mRunAnyAsync(Iterable<? extends Runnable> actions)	Iterable variant of CffuFactory.mRunAnyAsync(Runnable...).
Cffu<Void>	mRunAnyAsync(Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CffuFactory.mRunAnyAsync(Executor, Runnable...).
Cffu<Void>	mRunAnySuccessAsync(Iterable<? extends Runnable> actions)	Iterable variant of CffuFactory.mRunAnySuccessAsync(Runnable...).
Cffu<Void>	mRunAnySuccessAsync(Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CffuFactory.mRunAnySuccessAsync(Executor, Runnable...).
Cffu<Void>	mRunAsync(Iterable<? extends Runnable> actions)	Iterable variant of CffuFactory.mRunAsync(Runnable...).
Cffu<Void>	mRunAsync(Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CffuFactory.mRunAsync(Executor, Runnable...).
Cffu<Void>	mRunFailFastAsync(Iterable<? extends Runnable> actions)	Iterable variant of CffuFactory.mRunFailFastAsync(Runnable...).
Cffu<Void>	mRunFailFastAsync(Iterable<? extends Runnable> actions, Executor executor)	Iterable variant of CffuFactory.mRunFailFastAsync(Executor, Runnable...).
<E> MCffu<E,List<E>>	mSupplyAllSuccessAsync(E valueIfFailed, Iterable<? extends Supplier<? extends E>> suppliers)	Iterable variant of CffuFactory.mSupplyAllSuccessAsync(Object, Supplier[]).
<E> MCffu<E,List<E>>	mSupplyAllSuccessAsync(E valueIfFailed, Iterable<? extends Supplier<? extends E>> suppliers, Executor executor)	Iterable variant of CffuFactory.mSupplyAllSuccessAsync(Executor, Object, Supplier[]).
<T> Cffu<T>	mSupplyAnyAsync(Iterable<? extends Supplier<? extends T>> suppliers)	Iterable variant of CffuFactory.mSupplyAnyAsync(Supplier[]).
<T> Cffu<T>	mSupplyAnyAsync(Iterable<? extends Supplier<? extends T>> suppliers, Executor executor)	Iterable variant of CffuFactory.mSupplyAnyAsync(Executor, Supplier[]).
<T> Cffu<T>	mSupplyAnySuccessAsync(Iterable<? extends Supplier<? extends T>> suppliers)	Iterable variant of CffuFactory.mSupplyAnySuccessAsync(Supplier[]).
<T> Cffu<T>	mSupplyAnySuccessAsync(Iterable<? extends Supplier<? extends T>> suppliers, Executor executor)	Iterable variant of CffuFactory.mSupplyAnySuccessAsync(Executor, Supplier[]).
<E> MCffu<E,List<E>>	mSupplyAsync(Iterable<? extends Supplier<? extends E>> suppliers)	Iterable variant of CffuFactory.mSupplyAsync(Supplier[]).
<E> MCffu<E,List<E>>	mSupplyAsync(Iterable<? extends Supplier<? extends E>> suppliers, Executor executor)	Iterable variant of CffuFactory.mSupplyAsync(Executor, Supplier[]).
<E> MCffu<E,List<E>>	mSupplyFailFastAsync(Iterable<? extends Supplier<? extends E>> suppliers)	Iterable variant of CffuFactory.mSupplyFailFastAsync(Supplier[]).
<E> MCffu<E,List<E>>	mSupplyFailFastAsync(Iterable<? extends Supplier<? extends E>> suppliers, Executor executor)	Iterable variant of CffuFactory.mSupplyFailFastAsync(Executor, Supplier[]).
<E> MCffu<E,List<E>>	mSupplyMostSuccessAsync(E valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends Supplier<? extends E>> suppliers)	Iterable variant of CffuFactory.mSupplyMostSuccessAsync(Object, long, TimeUnit, Supplier[]).
<E> MCffu<E,List<E>>	mSupplyMostSuccessAsync(E valueIfNotSuccess, long timeout, TimeUnit unit, Iterable<? extends Supplier<? extends E>> suppliers, Executor executor)	Iterable variant of CffuFactory.mSupplyMostSuccessAsync(Executor, Object, long, TimeUnit, Supplier[]).

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 MCffu; otherwise, prefer simple method `mRunAsync`")
public <E> MCffu<E,List<E>> mSupplyFailFastAsync(Iterable<? extends Supplier<? extends E>> suppliers)

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

mSupplyFailFastAsync

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

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

mSupplyAllSuccessAsync

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

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

mSupplyAllSuccessAsync

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

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

mSupplyMostSuccessAsync

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

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

mSupplyMostSuccessAsync

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

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

mSupplyAsync

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

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

mSupplyAsync

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

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

mSupplyAnySuccessAsync

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

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

mSupplyAnySuccessAsync

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

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

mSupplyAnyAsync

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

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

mSupplyAnyAsync

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

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

mRunFailFastAsync

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

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

mRunFailFastAsync

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

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

mRunAsync

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

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

mRunAsync

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

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

mRunAnySuccessAsync

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

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

mRunAnySuccessAsync

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

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

mRunAnyAsync

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

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

mRunAnyAsync

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

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

allResultsFailFastOf

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

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

allSuccessResultsOf

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

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

mostSuccessResultsOf

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

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

allResultsOf

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

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

allFailFastOf

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

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

allOf

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

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

anySuccessOf

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

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

anyOf

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

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