如何创建由通量完成触发的单声道

Question

我有一个类，它从通量源填充地图。我希望能够动态地更新thedata（），但我希望能够返回解析为当前或挂起数据的Mono。

基本上如果数据！=null和no in progress flux，返回Mono。仅返回（数据），否则返回最终将发出数据的单声道。

编辑：这是目前为止我能做的最好的了

    class SomeClass {
        private Mono<Map<String, Data>> theData;
        private final SomeFluxService someFluxService = new SomeFluxService();

        public SomeClass() {
            updateTheData();
        }

        public void updateTheData() {
            someFluxService.get()
                .collectMap(Data::getId, Function.identity())
                .subscribe(d -> this.theData = Mono.just(d));
        }

        public Mono<Map<String, Data>> getTheData() {
            return this.theData;
        }
    }

但是仍然存在一个问题，在第一次完成updateTheData（）之前，getTheData（）将返回null

帮助赞赏！




Answer 1

但是仍然存在一个问题，在第一次完成updateTheData（）之前，getTheData（）将返回null

这是因为您在订阅方法中使用消费者仅在发出数据时更新Mono。这是一种有点奇怪的方法，最好简单地cache（）Mono然后立即将其分配给您的字段：

public void updateTheData() {
    theData = someFluxService.get()
            .collectMap(Data::getId, Function.identity())
            .cache();
}

更进一步，如果您的要求是每隔x秒更新一次数据，而不是按需更新，您可以将其传递给缓存函数并完全取消单独的方法：

public NewClass() {
    theData = someFluxService.get()
            .collectMap(Data::getId, Function.identity())
            .cache(Duration.ofMinutes(5));
}

public Mono<Map<String, Data>> getTheData() {
    return theData;
}