static <T,U> StageChain<List<T>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
int chunkSize,
Iterable<? extends Supplier<? extends StageChain<? extends T,T>>> stageFactories) |
Waits for all stages to complete normally, then returns a list with the result of each stage, in that order.
|
static <T,R,U> StageChain<List<R>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
int chunkSize,
Function<? super T,? extends R> fn,
Iterable<? extends Supplier<? extends StageChain<? extends T,R>>> stageFactories) |
Similar to allOf, but additional partitions the stages into chunks of a given size and processes the chunks in
order.
|
static <T,R,U> StageChain<List<R>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
int chunkSize,
Function<? super T,? extends R> fn,
Supplier<? extends StageChain<? extends T,R>>... stageFactories) |
Similar to allOf, but additional partitions the stages into chunks of a given size and processes the chunks in
order.
|
static <T,R,U> StageChain<List<R>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
int chunkSize,
Function<? super T,? extends R> fn,
Stream<? extends Supplier<? extends StageChain<? extends T,R>>> stageFactories) |
Similar to allOf, but additional partitions the stages into chunks of a given size and processes the chunks in
order.
|
static <T,U> StageChain<List<T>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
int chunkSize,
Supplier<? extends StageChain<? extends T,T>>... stageFactories) |
Waits for all stages to complete normally, then returns a list with the result of each stage, in that order.
|
static <T,U> StageChain<List<T>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
int chunkSize,
Stream<? extends Supplier<? extends StageChain<? extends T,T>>> stageFactories) |
Waits for all stages to complete normally, then returns a list with the result of each stage, in that order.
|
static <T,U> StageChain<List<T>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
StageChain<? extends T,T>... stages) |
Waits for all stages to complete normally, then returns a list with the result of each stage, in that order.
|
static <T,U> StageChain<List<T>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
Iterable<? extends StageChain<? extends T,T>> stages) |
Waits for all stages to complete normally, then returns a list with the result of each stage, in that order.
|
static <T,R,U> StageChain<List<R>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
Function<? super T,? extends R> fn,
StageChain<? extends T,R>... stages) |
|
static <T,R,U> StageChain<List<R>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
Function<? super T,? extends R> fn,
Iterable<? extends StageChain<? extends T,R>> stages) |
|
static <T,R,U> StageChain<List<R>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
Function<? super T,? extends R> fn,
Stream<? extends StageChain<? extends T,R>> stages) |
|
static <T,U> StageChain<List<T>,U> |
XStageChainUtils.allOf(IStageChainFactory rsf,
Stream<? extends StageChain<? extends T,T>> stages) |
Waits for all stages to complete normally, then returns a list with the result of each stage, in that order.
|