Flux — ключевой компонент библиотеки Project Reactor, которая широко используется для реактивного программирования на Java. При работе с Flux доступны различные методы для сбора всех элементов, создаваемых Flux, в список. В этой статье мы рассмотрим несколько методов и приведем примеры кода для каждого из них.

Метод 1: CollectList()
Оператор CollectList() — это встроенный метод, предоставляемый Project Reactor. Он собирает все элементы, созданные Flux, и возвращает их как Mono>.

Flux<Integer> flux = Flux.just(1, 2, 3, 4, 5);
Mono<List<Integer>> listMono = flux.collectList();

Метод 2: Collect(Collectors.toList())
Вы также можете использовать метод Collect() из Stream API в Java для сбора элементов, созданных Flux, в список.

import java.util.stream.Collectors;
Flux<Integer> flux = Flux.just(1, 2, 3, 4, 5);
List<Integer> list = flux.collect(Collectors.toList()).block();

Метод 3: toStream().collect(Collectors.toList())
Другой подход — преобразовать Flux в поток, а затем использовать метод Collect() API Stream для сбора элементов в список.

import java.util.stream.Collectors;
Flux<Integer> flux = Flux.just(1, 2, 3, 4, 5);
List<Integer> list = flux.toStream().collect(Collectors.toList());

Метод 4: CollectList() с помощью FlatMapMany()
Если у вас есть Flux из Flux, вы можете использовать FlatMapMany(), чтобы свести его в один Flux, а затем использовать CollectList(), чтобы собрать все элементы в один Flux. список.

Flux<Flux<Integer>> fluxOfFluxes = Flux.just(Flux.just(1, 2), Flux.just(3, 4), Flux.just(5));
Mono<List<Integer>> listMono = fluxOfFluxes.flatMapMany(flux -> flux).collectList();

Метод 5: CollectList() с помощью FlatMap()
Подобно предыдущему методу, если у вас есть объект Flux Mono, вы можете использовать FlatMap(), чтобы свести его в один Flux, а затем использовать CollectList() собрать все элементы в список.

Flux<Mono<Integer>> fluxOfMonos = Flux.just(Mono.just(1), Mono.just(2), Mono.just(3));
Mono<List<Integer>> listMono = fluxOfMonos.flatMap(mono -> mono).collectList();

Метод 6: уменьшить() с ArrayList
Оператор уменьшить() позволяет накапливать элементы, излучаемые Flux, и выполнять над ними операции. Используя оператор уменьшения() с ArrayList, вы можете собрать все элементы, созданные Flux, в список.

import java.util.ArrayList;
Flux<Integer> flux = Flux.just(1, 2, 3, 4, 5);
Mono<ArrayList<Integer>> listMono = flux.reduce(new ArrayList<>(), (list, item) -> {
    list.add(item);
    return list;
});

В этой статье мы рассмотрели различные методы сбора элементов, создаваемых Flux, в список. Мы рассмотрели встроенные операторы, такие как CollectList(), а также использование операторов Stream API, FlatMap() и Reduc(). В зависимости от вашего конкретного случая использования и требований вы можете выбрать метод, который лучше всего соответствует вашим потребностям.