如何链接调用

编程问答 2022-05-10

问题描述

我的问题必须非常基本，但感谢您的帮助

我有一个像下面这样的对象

{
    "type":"type_value","fruits" :[{"amt": 5},{"amt": 10}],"shops" : [{"location": "X"},{"location": "Y"}]
}

我正在使用 Spring WebFlux 和 couchbase。 Couchbase 支持集合，我希望将上面的对象存储在 3 个集合中。水果/商店数组可以包含任意数量的元素。

Couchbase 具有“插入”功能，它在一次插入时返回 Mono。 例如

第 1 步：

Mono<TransactionGetResult> insertResult = ctx.insert(reactiveCollectio,id,objectToPersist)

我只能在“insertResult”对象上插入下一个元素。像下面 第 2 步：

 Mono<TransactionGetResult> insertResult = insertResult.then(ctx.insert(reactiveCollectio,objectToPersist));

现在再次，如果我想插入下一个元素，我必须遵循与步骤 2 相同的操作，并继续执行直到完成，然后我才能提交事务。

使用 reactor api 的如何迭代以及如何使用先前的结果 ( Mono<TransactionGetResult> insertResult ) 来执行我的插入？

解决方法

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

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

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

couchbasereactorreactorreactorreactorspring-webflux