在计划任务中使用Flux

我正在从事Spring Webflux项目，并且在尝试在计划任务中发布和使用Flux时遇到了问题。

@Scheduled(fixedRate = 20*1000)
fun updateNews() {
    try {
        logger.info("Automatic Update at: ${LocalDateTime.now()}")
        articleRepository.saveAll(
                sourceRepository.findAll().publishOn(Schedulers.parallel())
                        .map { source -> source.generate() }
                        .flatMap { it?.read() ?: Flux.empty() })
                        .timeout(Duration.ofSeconds(20)
        ).subscribeOn(Schedulers.parallel())
    } catch(e: Throwable) {
        logger.log(Level.SEVERE, "Error in Scheduler", e)
    }
}

我配置的调度程序：

ConcurrentTaskScheduler(Executors.newScheduledThreadPool(3))

除非我有意阻止，否则此任务将永远不会完成：

.then().block()

我最初并不理会直接引用发布/订阅调度程序的问题，并且我尝试了所有看似合理的方案，但没有任何效果。

我的日志事件发生了，但似乎当调度程序中用于此任务的线程死亡时，通量也被清除了；即使我指定了publishOn和subscriptionOn行为后，它们也应该位于自己的线程池中？

我想使此操作完全被动，请提供任何建议。