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

Class ReactorUtils

java.lang.Object

uk.ac.ebi.utils.opt.runcontrol.ReactorUtils

public class ReactorUtils
extends Object

Utilities based on the Project Reactor library.

Author:

Marco Brandizi

Date:

29 Jun 2024

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReactorUtils.ParallelBatchFluxBuilder<T,B extends Collection<T>>	Little helper to build a common ParallelFlux to process a source of items in parallel batches.

Constructor Summary

Constructors

Constructor	Description
ReactorUtils()

Method Summary

Modifier and Type	Method	Description
static <T> void	batchProcessing(Collection<T> collection, Consumer<List<T>> task)	Variant of batchProcessing(Flux, Consumer)
static <T> void	batchProcessing(Stream<T> stream, Consumer<List<T>> task)	Variant of batchProcessing(Flux, Consumer)
static <T> void	batchProcessing(reactor.core.publisher.Flux<T> flux, Consumer<List<T>> task)	Uses ReactorUtils.ParallelBatchFluxBuilder with default options and batchProcessing(ParallelFlux, Consumer) to batch a source of items and process them in parallel batches.
static <T, B extends Collection<? super T>> void	batchProcessing(reactor.core.publisher.ParallelFlux<B> parallelFlux, Consumer<B> task)	Uses ReactorUtils.ParallelBatchFluxBuilder to process a source of batches.
static <T> reactor.core.publisher.ParallelFlux<List<T>>	parallelBatchFlux(Collection<? extends T> collection)	Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.
static <T> reactor.core.publisher.ParallelFlux<List<T>>	parallelBatchFlux(Stream<? extends T> stream)	Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.
static <T> reactor.core.publisher.ParallelFlux<List<T>>	parallelBatchFlux(reactor.core.publisher.Flux<? extends T> flux)	Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.

Methods inherited from class java.lang.Object

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

Constructor Details

ReactorUtils

public ReactorUtils()

Method Details

parallelBatchFlux

public static <T>
reactor.core.publisher.ParallelFlux<List<T>> parallelBatchFlux(reactor.core.publisher.Flux<? extends T> flux)

Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.

parallelBatchFlux

public static <T>
reactor.core.publisher.ParallelFlux<List<T>> parallelBatchFlux(Stream<? extends T> stream)

Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.

parallelBatchFlux

public static <T>
reactor.core.publisher.ParallelFlux<List<T>> parallelBatchFlux(Collection<? extends T> collection)

Just uses ReactorUtils.ParallelBatchFluxBuilder with its defaults.

batchProcessing

public static <T,
B extends Collection<? super T>>
void batchProcessing(reactor.core.publisher.ParallelFlux<B> parallelFlux,
 Consumer<B> task)

Uses ReactorUtils.ParallelBatchFluxBuilder to process a source of batches.

batchProcessing

public static <T> void batchProcessing(reactor.core.publisher.Flux<T> flux,
 Consumer<List<T>> task)

Uses ReactorUtils.ParallelBatchFluxBuilder with default options and batchProcessing(ParallelFlux, Consumer) to batch a source of items and process them in parallel batches.

batchProcessing

public static <T> void batchProcessing(Stream<T> stream,
 Consumer<List<T>> task)

Variant of batchProcessing(Flux, Consumer)

batchProcessing

public static <T> void batchProcessing(Collection<T> collection,
 Consumer<List<T>> task)

Variant of batchProcessing(Flux, Consumer)