如何在Couchbase Java SDK 3.x中使用Scala中的JsonDocument?

omvjsjqw  于 2023-06-29  发布在  Scala
关注(0)|答案(1)|浏览(131)

我正在尝试从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()
xa9qqrwz

xa9qqrwz1#

flatMap函数没有任何问题。你需要做的唯一的事情就是把java列表转换成scala列表,如下所示

val reactiveCollection = bucket.scope("default").collection("default").reactive
  val docsToFetch: util.List[String] = java.util.Arrays.asList("doc1", "doc2")

  import scala.collection.JavaConverters._

  val fetchedResult: List[GetResult] = Flux.fromIterable(docsToFetch)
    .flatMap { key => reactiveCollection.get(key) }
    .collectList()
    .block().asScala.toList

相关问题