scala - mongo-scala-driver：如何在 Observable 中捕获部分结果和解码错误？

Question

在使用查找操作时，有没有办法将新出现的解码异常和数据捕获为值？

在解码所有检索到的 BSON 时，有些可能具有无效属性，并且无法解码为域对象。

我的想法是：

  val findAsyncResult: Future[List[Either[DecodingExceptions, Data]]] =
      database
        .getCollection[String](???)
        .find(???)
        .toFuture()
}

我注意到，当一个值无法解码时，整个操作都会失败。我在跳跃，我可以以某种方式积累错误和有效数据。