相互依赖的期货组合
相互依赖的期货组合
提问于 2015-05-22 01:13:49
我使用Scala向API (确切地说，是Play Framework的WS )发出HTTP请求，该API用一个JSON响应来响应，类似于；
{
data: [
{text: "Hello there", id: 1},
{text: "Hello there again", id: 2}
],
next_url: 'http://request-this-for-more.com/api?page=2' //optional
}因此，返回的JSON中的next_url字段可能存在，也可能不存在。
我的方法需要做的是从调用第一个URL开始，检查响应是否有next_url，然后对其执行GET。最后，我应该将来自响应的所有data字段组合成所有数据字段的一个未来。当响应中没有next_url时，我将终止它。
现在，用阻塞的方式做这件事比较容易，但我不想这样做。解决这样的问题最好的办法是什么？
回答 2
Stack Overflow用户
回答已采纳
发布于 2015-05-22 01:33:09
在scalaz中可能有这样的方法，但是如果您不知道一个特定的解决方案，通常可以使用递归和flatMap来构造一个解决方案。类似于：
//Assume we have an async fetch method that returns Result and Option of next Url
def fetch(url: Url): Future[(Result, Option[Url])] = ...
//Then we can define fetchAll with recursion:
def fetchAll(url: Url): Future[Vector[Result]] =
fetch(url) flatMap {
case (result, None) => Future.successful(Vector(result))
case (result, Some(nextUrl)) =>
fetchAll(nextUrl) map {results => result +: results}
}(请注意，这对每个调用都使用了一个堆栈框架-如果您想要执行数千次获取，那么我们需要更仔细地编写它，以便它是尾递归的)
Stack Overflow用户
发布于 2015-05-22 01:33:39
这种情况下，Future.flatMap方法确实存在。
假设你有这样的东西：
case class Data(...)
def getContent(url:String):Future[String]
def parseJson(source:String):Try[JsValue]
def getData(value: JsValue):Seq[Data]JsValue类型有受播放json图书馆启发的方法
def \ (fieldName: String): JsValue
def as[T](implicit ...):T //probably throwing exception你可以写最后的结果
def innerContent(url:String):Future[Seq[Data]] = for {
first <- getContent(url)
json <- Future.fromTry(parseJson(first))
nextUrlAttempt = Try((json \ "next_url").as[String])
dataAttempt = Try(getData(json \ "data"))
data <- Future.fromTry(dataAttempt)
result <- nextUrlAttempt match {
case Success(nextUrl) => innerContent(nextUrl)
case Failure(_) => Future.successful(Seq())
} yield data ++ result还可以查看针对像您这样的复杂异步流的库：
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/30392773
复制
相似问题
scala，play，期货:组合多个期货的结果
组合功能，回报期货
期货与期权组合
如何实现期货组合
如何组合多个期货的Single<T>
添加站长 进交流群
领取专属 10元无门槛券
AI混元助手 在线答疑
关注 腾讯云开发者公众号
洞察 腾讯核心技术
剖析业界实践案例
腾讯云开发者
