使用反应式方法几次操作后如何保存获得的值

问题描述

我想知道使用正确的反应性方法处理Mono或Flux的最佳方法。

我想在进行几次操作后从Mono获得初始值。 例如：

public Mono<SomeObject> test(Mono<Object> object) {
        return object
                .map(this::buildRequestFromObject)
                .flatMap(this::sendRequest)
                .flatMap(this::anotherUsefulWorkWithReturnImpotant)          (1)
                .then(object) <-- is it okay???                                 
                .onErrorResume(this::handleExceptionAndDoSomeWork)           (2)
                .doOnSuccess(object-> saveThisObject(object))                (3)
                .then();
    }

1. 我需要转换值并做一些工作，但结果不为空，否则为异常
2. 如果（1）丢了东西，我需要处理异常之后
3. 如果（1）无一例外地完成，我应该保存原始对象。

这是最好的方法吗？或者也许我应该使用subcribeContext例如？

非常感谢您的帮助！

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）