在进行 Web 服务调用时将 Promise[Option[Model]] 转换为 Promise[Option[String]]

Question

我有两个web服务调用。Webservice1返回Promise[Option[Model]]，Webservice2应该以Model为参数，然后返回一个Promise[Option[String]]。我是这样构建我的代码的:

  def call1: Promise[Option[Model]] = for {
    response1 <- callService1(requestHolderForService1)
  } yield {
    for {
      response <- response1
    } yield ParserForResponse(response)
  }

之后，我想将我的调用链接到服务2，它将服务1的结果作为参数：

   def call2:Promise[Option[String]] = call1.flatMap{
    optionModel => optionModel.flatMap{
      model => callService2(requestHolderForService2(model)).map{
        service2Option => service2Option.map{
          service2Result => ResultParse(service2Result)
        }
      }
    }
  }

问题是，我的call1返回一个Promise[Option[Model]]，而call2的返回需要是Promise[Option[String]]。这个问题源于中间服务调用

CallService2

它返回Promise[Option[JsValue]]并且我无法弄清楚从Promise[Option[Model]]的转换-

有人能指出我如何使用map或flatMap将这两个调用链接在一起吗？

谢谢




Answer 1

“正常”方式不是直接处理promise，而是这些promise的未来，您可以从scala.concurrent.Promise.future访问这些promise

首先，您映射未来，将其视为当选项到达时，对其进行此转换，然后您需要处理该选项可能不存在的事实，这也是一个映射，将其视为该转换的值。

所以:

val future1: Future[Option[Model]] = (...).future
val future2: Future[Option[String]] = future1.map { maybeModel => 
  maybeModel.map(model => model.toString) // or hovewer you make it a string
}

然后您可以在第二次Web服务调用中使用它