如何解决使用反应式方法几次操作后如何保存获得的值
我想知道使用正确的反应性方法处理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)丢了东西,我需要处理异常之后
- 如果(1)无一例外地完成,我应该保存原始对象。
这是最好的方法吗?或者也许我应该使用subcribeContext例如?
非常感谢您的帮助!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。