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.