如何将Flux<List<T>>扁平化为Flux<T>？

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.util.List;

public <T> Flux<T> flattenFlux(Flux<List<T>> fluxOfLists) {
    return fluxOfLists
            .flatMap(list -> Flux.fromIterable(list));
}

public class Main {
    public static void main(String[] args) {
        Flux<List<Integer>> fluxOfLists = Flux.just(
                List.of(1, 2, 3),
                List.of(4, 5, 6),
                List.of(7, 8, 9)
        );

        Main main = new Main();
        Flux<Integer> flattenedFlux = main.flattenFlux(fluxOfLists);

        flattenedFlux.subscribe(System.out::println);
    }

    public <T> Flux<T> flattenFlux(Flux<List<T>> fluxOfLists) {
        return fluxOfLists
                .flatMap(list -> Flux.fromIterable(list));
    }
}

1
2
3
4
5
6
7
8
9