list - 按顺序调用任意数量的 WS.url().get()

Question

我有一个 URL 列表[字符串]，我想按顺序加载和处理(解析、存储到数据库)。

我只找到了固定长度的示例，例如:

    def readUrls = Action {
    implicit request => {
        implicit val context = scala.concurrent.ExecutionContext.Implicits.global

        val url1 = "http://some-website.com"
        val url2 = "http://other-website.com"

        Async {
            for {
                result1 <- WS.url(url1).get()
                result2 <- WS.url(url2).get()
            } yield {
                Ok(result1.body + result2.body)
            }
        }
}

但是我需要处理这只小狗，而不是 url1 和 url2:

val urls = List("http://some-website.com", "http://other-website.com")

非常感谢您的任何提示和建议!

Answer 1

如果您想按顺序将 Future 任意链接在一起，foldLeft 应该可以完成这项工作:

urls.foldLeft(Future.successful[String]("")){ case (left, nextUrl) =>
    left.flatMap{ aggregatedResult =>
        WS.url(nextUrl).get().map( newResult =>
            aggregatedResult + newResult.body
        )
    }
}

由于您只是将请求主体组合在一起，因此我给了 foldLeft 一个 Future 空 String 的初始值，每个折叠中的步骤将添加到下一个响应正文。