微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

如何链接调用

如何解决如何链接调用

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

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

{
    "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 举报,一经查实,本站将立刻删除。