在未来序列中迭代未来序列

Question

我正在开发一个用Scala编写的PlayFramework应用程序。

问题在于，在rest控制器中，我需要一个元素列表（书籍），每个元素都需要一个子元素列表（章节）。

图书仓库:

def findAll(): Future[Seq[Book]] 

章节存储库：

def findByBookId(bookId: UUID): Future[Seq[Chapter]]

我想做一些像

val books = bookRepository.findAll
val result = for {
  bookList <- books
  book <- bookList
  chapters <- chapterRepository.findByBookdId(book.id)
} yield (book, chapters)

我想要一个图书及其章节的元组，这样我可以稍后将它映射到一个json。我做错了什么，因为我得到错误:

[error]  required: scala.collection.GenTraversableOnce[?]

或者什么是更好的方法，如何迭代集合的未来，并为每个元素加载另一个集合的未来？

Answer 1

在整个理解过程中，应使用相同的类型。

你不能有书：未来[Seq[书]和书列表：书包[书]在同一个理解。

您也可以使用< code>Future.sequence将< code>Seq[Future某物]]转换为< code>Future[Seq某物]]

所以，像这样的东西应该有效

val res: Future[(Seq[Book], Seq[Chapter])] =
for {
  bookList <- books
  chapters <- Future.sequence(bookList.map(book => findByBookId(book.id)))
} yield (bookList, chapters.flatten)

Answer 2

您只能在 a 中使用一种类型的 monad 进行理解，因为它只是 flatMap 和 map 的语法糖。

请参阅此处的完整描述：https://stackoverflow.com/a/33402543/2750966

Answer 3

看看这是否能让你接近你所追求的。

// found books (future)
val fBooks :Future[Seq[Book]] = bookRepository.findAll()

// chapters in fBooks order (future)
val fChptrs :Future[Seq[Seq[Chapter]]] = fBooks.flatMap {books =>
  Future.sequence(books.map(book =>findByBookId(book.id)))
}

// combine book with its chapters
val result :Future[Seq[(Book, Seq[Chapter])]] = for {
  books <- fBooks
  chptrs <- fChptrs
} yield books zip chptrs