如何在迭代 Flux 时更新属性值

How to update attribute value while iterating Flux

提问人:Loren 提问时间:11/15/2023 最后编辑:Lex LiLoren 更新时间:11/15/2023 访问量:20

问:

我想使用另一个列表中存在的值更新列表中每个项目的属性值。我正在尝试通过Map进行操作,但它给了我编译错误。有人可以建议正确的方法是什么吗?我是反应式的新手。

private void updatePaymentDocument(Payment paymentDoc, PaymentTransaction txn) {
    Flux.fromIterable(paymentDoc.getPaymentMethods())
    .filter( pm-> pm.getSequenceNo().equalsIgnoreCase(txn.getSequenceNo()))
    .map(pm -> pm.setTotalRefundAmount(txn.getPaymentAuthorization().getAuthorizedAmount()));
}
Java 反应 通量

评论

0赞 Peng 11/15/2023
如果你正在做一些事情,比如消费者,而不是供应商,你可以尝试使用DoonNext而不是Map,Map用于将模型从上游转移到下游
1赞 Rob Spoor 11/15/2023
map需要返回一个值。 很可能具有返回类型。除了使用之外,您还可以尝试使用块:FunctionsetTotalRefundAmountvoiddoOnNext{ pm.setTotalRefundAmount(...); return pm; }

答: 暂无答案