Play 2.2 -Scala – 如何在Controller Action中链接Futures

发布时间：2020-12-16 18:35:42 所属栏目：安全来源：网络整理

导读：我有3个类型为Response的期货.第一个未来返回一个JsValue,它定义是否将执行future 2和future 3,或者只执行future 3. 伪代码：如果未来1那么{future2和future 3} 别的未来3 我试图在一个游戏框架动作中这样做,这意味着为了使用后期的结果我不能使用onSuccess

我有3个类型为Response的期货.第一个未来返回一个JsValue,它定义是否将执行future 2和future 3,或者只执行future 3.

伪代码：
如果未来1那么{future2和future 3}
别的未来3

我试图在一个游戏框架动作中这样做,这意味着为了使用后期的结果我不能使用onSuccess,onFailure和onComplete,因为所有这些都返回Unit而不是最后一个实际的JsValue.

我试着用map()和andThen做这个,但我是Scala noob,我想我无法做到这一点,因为我总是错过了一点点.这是我目前的方法不起作用！

def addSuggestion(indexName: String,suggestion: String) = Action.async {
  val indexExistsQuery: IndexExistsQuery = new IndexExistsQuery(indexName);
  val addSuggestionQuery: AddSuggestionQuery = new AddSuggestionQuery(indexName,suggestion)
  val indexCreationQuery: CreateCompletionsFieldQuery = new CreateCompletionsFieldQuery(indexName)

  val futureResponse: Future[Response] = for {
    responSEOne <- EsClient.execute(indexExistsQuery)
    responseTwo <- EsClient.execute(indexCreationQuery) if (indexExistsQuery.getBooleanResult(indexExistsQuery.getResult(responSEOne)))
    responseThree <- EsClient.execute(addSuggestionQuery)
  } yield responseThree

  futureResponse.map { response =>
  Ok("Feed title: " + (response.json))
}

解决方法

我创建了一些伪代码：

checkIndexExists() map {
  case true => Future.successful()
  case false => createIndex()
} flatMap { _ =>
  query()
}.map { response =>
  Ok("Feed title: " + (response.json))
}.recover { 
  case _ => Ok("bla") 
}

首先,如果索引存在,则启动查询.
然后,如果成功,您将映射未来如何使用Future [Boolean].由于您使用map,因此您可以提取布尔值.如果索引存在,则只需创建已完成的未来.如果索引不存在,则需要启动索引创建命令.现在您已经拥有了嵌套Future(Future [Future [Response]])的情况.使用flatMap可以删除一个维度,这样您就只有Future [Response].这可以映射到播放结果.

更新(MeiSign的实施)：

EsClient.execute(indexExistsQuery) map { response =>
      if (indexExistsQuery.getBooleanResult(indexExistsQuery.getResult(response))) Future.successful(Response)
      else EsClient.execute(indexCreationQuery)
    } flatMap { _ =>
      EsClient.execute(addSuggestionQuery)
    } map { response: Response =>
      Ok("Feed title: " + (response.json))
    }

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!