Объедините несколько моно в поток

Question

Я добавляю Flux с flatMap, но если я добавлю дополнительные flatMap, будет возвращен только последний.

// Here is an example of the Mono function

private Mono<MyType> appendFirstMono(Group group) {
    return Mono.just(group)
    .map(MyType::new)
        .flatMap(g -> functionZ(group)
        .map(g::setField));
} 


//This works as expected

public Flux<MyType> function1() {

    return returnData(id)
            .thenMany(service.getData(id))
            .flatMap(this::appendFirstMono);
}

//This does not and only returns the last mono (3rd)

public Flux<MyType> function1() {

    return returnData(id)
            .thenMany(service.getData(id))
            .flatMap(this::appendFirstMono)
            .flatMap(this::appendSecondMono)
            .flatMap(this::appendThirdMono);
}

//I've attempted to fix with this... Doesn't work as expected.   

public Flux<MyType> function1() {

    return returnData(id)
            .thenMany(service.getData(id))
            .flatMap(x -> {
                return Flux.merge(
                    appendFirstMono(x),
                    appendSecondMono(x),
                    appendThirdMono(x)
                );
            });
}

Мне нужно обработать каждую функцию Mono на Flux, но я не могупохоже, каждый выполняет и возвращается правильно.

Answer 1

Вы можете попробовать concat для обработки моно один за другим, посмотрите мой пример

        Flux.concat(getMono(0),getMono(1),getMono(2))
            .map(integer -> {
                System.out.println(integer);
                return integer;
            })
            .subscribe();

}

private Mono<Integer> getMono(Integer a) {
    return Mono.just(a)
            ;
}

это напечатает 0,1,2