时间戳

首页 > 解决方案 > runOn 后跟 subscribeOn FLUX 不工作

spring-boot - runOn 后跟 subscribeOn FLUX 不工作

问题描述

我的流程是这样的，我正在使用 Flux.generate 在单独的线程上进行 Sqs 轮询，并将通量发送到并行处理通量的类，这不起作用

我的轮询器是这样的

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，在其他类中使用 runOn 这会导致任何问题”

标签： spring-bootspring-webfluxfluxreactor

解决方案

推荐阅读