0

我正在使用Mongo Scala Driver从 MongoDb 读取文档。我有以下方法返回Future[List[T]]

def findAll(): List[Future[List[T]] = {
   db.getCollection(collectionName)
      .find(queryObject)
      .toFuture()
      .map{
        results => results.map(/* converting result to T */).toList
      }
}

问题:

而不是一个列表,有没有办法,这个方法可以返回Iterator[T]Future[Iterator[T]]

该文档提到了关于iterating the results via the subscribe method,但我找不到任何具体的实现或使用此subscribe方法来实现我的用例的示例。

4

0 回答 0