Как перебрать кортеж с помощью zipWith во Flux?

Я хочу перебрать базовый список, который предлагает referenceIds. Затем на следующем этапе я хочу сделать несколько вызовов службы и объединить результаты в кортеж.

Затем, в качестве последнего шага, я хочу перебрать все мои referenceIds и вернуть каждый сгенерированный JSONObject напрямую через поток событий.

@GetMapping(value = "/test", produces = TEXT_EVENT_STREAM_VALUE)
public Flux<JSONObject> test(Integer pages) {
    pages = 1;
    return Flux.range(1, pages)
            .map(pageNumber -> Arrays.asList(1 * pageNumber, 2 * pageNumber, 3 * pageNumber)) //referenceIds for testing
            .flatMap(numbers -> Flux.fromIterable(numbers).zipWith(Mono.zip(a(numbers), b(numbers)))) //results based on reference ids
            .map(tuple -> {
                Integer number = tuple.getT1();
                Tuple2<List<String>, List<String>> lookup = tuple.getT2();

                JSONObject json = new JSONObject();
                json.put("number", number);
                json.put("someMore", <fromLookup>);
                return json;
            });
}

Для этого примера возвращаемые типы методов a() и b() не имеют значения. Важная часть:

Если просто вернуть Flux.fromIterable(numbers); все работает нормально. НО при агрегировании с использованием .zipWith() я получаю только 1-й элемент списка чисел. Все остальные потеряны. Почему?

Примечание: мне нужно использовать .zipWith() для параллельного выполнения этих вызовов методов (некоторые более длительные транзакции).