Uses of Class
uk.ac.ebi.utils.opt.runcontrol.ReactorUtils.ParallelBatchFluxBuilder

Packages that use ReactorUtils.ParallelBatchFluxBuilder

Package	Description
uk.ac.ebi.utils.opt.runcontrol

Uses of ReactorUtils.ParallelBatchFluxBuilder in uk.ac.ebi.utils.opt.runcontrol

Methods in uk.ac.ebi.utils.opt.runcontrol that return ReactorUtils.ParallelBatchFluxBuilder

Modifier and Type	Method	Description
ReactorUtils.ParallelBatchFluxBuilder<T,B>	ReactorUtils.ParallelBatchFluxBuilder.withBatchSize(int batchSize)	The parallel flux scheduler to use.
ReactorUtils.ParallelBatchFluxBuilder<T,B>	ReactorUtils.ParallelBatchFluxBuilder.withBatchSupplier(Supplier<? extends Collection<? super T>> batchSupplier)	Default is null, which falls back to Flux.buffer(int), usually a List supplier.
ReactorUtils.ParallelBatchFluxBuilder<T,B>	ReactorUtils.ParallelBatchFluxBuilder.withParallelism(int parallelism)	The degree of parallelism of the resulting flux.
ReactorUtils.ParallelBatchFluxBuilder<T,B>	ReactorUtils.ParallelBatchFluxBuilder.withParallelismPreFetch(int parallelismPreFetch)	The prefetch parameter passed to Flux.parallel(int, int).
ReactorUtils.ParallelBatchFluxBuilder<T,B>	ReactorUtils.ParallelBatchFluxBuilder.withScheduler(reactor.core.scheduler.Scheduler scheduler)	The scheduler used to run the resulting flux.

Method parameters in uk.ac.ebi.utils.opt.runcontrol with type arguments of type ReactorUtils.ParallelBatchFluxBuilder

Modifier and Type	Method	Description
reactor.core.publisher.ParallelFlux<B>	ReactorUtils.ParallelBatchFluxBuilder.build(Consumer<ReactorUtils.ParallelBatchFluxBuilder<? super T,? super B>> visitor)
static <T> reactor.core.publisher.ParallelFlux<List<T>>	ReactorUtils.parallelBatchFlux(Collection<? extends T> collection, Consumer<ReactorUtils.ParallelBatchFluxBuilder<? super T,? super List<T>>> visitor)	Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.
static <T> reactor.core.publisher.ParallelFlux<List<T>>	ReactorUtils.parallelBatchFlux(Stream<? extends T> stream, Consumer<ReactorUtils.ParallelBatchFluxBuilder<? super T,? super List<T>>> visitor)	Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.
static <T> reactor.core.publisher.ParallelFlux<List<T>>	ReactorUtils.parallelBatchFlux(reactor.core.publisher.Flux<? extends T> flux, Consumer<ReactorUtils.ParallelBatchFluxBuilder<? super T,? super List<T>>> visitor)	Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.