Опрос площадей с использованием проектного реактора

Question

Как мне объединить 2 потока, которые выполняют опрос в SQS с использованием Flux.generate Когда я пытаюсь использовать flux.merge, кажется, что работает только первый пул Как мне выполнить опрос и объединение с обратным давлением

 flux= Flux.generate(messageSynchronousSink -> {
                log.info("First Flux");
                List<Message> messages = sqs.receiveMessage(receiveRequest).getMessages();
                m
 flux1=Flux.generate(messageSynchronousSink -> {
                log.info("Second Flux2");
                List<Message> messages = sqs1.receiveMessage(receiveRequest).getMessages();
                messageSynchronousSink.next(messages);
            });
 Flux.merge(flux1,flux1)
               .subscribe(System.out::println);