我正在尝试从Couchbase Java-sdk 2.7.23迁移到3.x。无法在Scala中使用以下命令解析flatMap。
从Couchbase获取多个文档时无法解析flatMap()
val reactiveCollection = bucket.scope("default").collection("default").reactive()
val docsToFetch = util.Arrays.asList("doc1", "doc2").toList
val fetchedResult: List[GetResult] = Flux.fromIterable(docsToFetch)
.flatMap(key => reactiveCollection.get(key))
.collectList()
.block()
1条答案
按热度按时间xa9qqrwz1#
flatMap函数没有任何问题。你需要做的唯一的事情就是把java列表转换成scala列表,如下所示