如何解决在 Reactor 中实现异步副作用的最佳方法是什么？
假设我有一个主链进行一些处理，我想对每个处理的项目调用计费服务，然后进一步返回处理结果，如下所示：
... ... ... // chain starts somewhere here
.flatMap(item -> processItem(item))
.doOnNext(item -> billingService.bill(item))
... ... ... // continue to work with processed items
即我想在链上做一些副作用动作。如果 billingService.bill() 是同步的，这将起作用，但它返回 Mono。
所以，这是我必须做的：
... ... ... // chain starts somewhere here
.flatMap(item -> processItem(item))
.flatMap(item -> billingService.bill(item).thenReturn(item))
... ... ... // continue to work with processed items
有没有更好的方法来做到这一点？对我来说似乎有点尴尬...
解决方法
您正在寻找的是“即发即弃”执行。请在这里阅读： Fire and forget with reactor
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
