我正在使用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
方法来实现我的用例的示例。