runOn с последующим подписанием FLUX не работает - PullRequest
Новая
       94

runOn с последующим подписанием FLUX не работает

0 голосов
/ 08 мая 2020

Мой поток выглядит так: Я выполняю опрос Sqs в отдельном потоке с помощью Flux.generate и отправляю поток в класс, который обрабатывает поток параллельно, который не работает

Мой опросчик работает следующим образом 

return Flux.generate(synchronousSink -> {
        log.info(queueName + " queue Polling ...");
        List<Message> messages = sqs.receiveMessage(receive_request).getMessages();
        synchronousSink.next(messages);
    })

            .subscribeOn(Schedulers.parallel());

и мои операции с потоком выглядят следующим образом 

  events.parallel()
            .runOn(Schedulers.parallel())
            .doOnNext(t->log.info("Not printing anything"))
            .subscribe();

События не появляются после runOn, если я удалил runOn, они работают нормально, может ли кто-нибудь помочь мне здесь Примечание - «Я Я использую subscibeOn в poller и runOn в классе Other, вызывает ли это какие-либо проблемы "

...