Scala：拦截函数以向 Akka 期货提供隐式参数

Question

好的，所以我对返回Akka Futures的函数进行了一系列调用，并且我通过使用flatMap和map将它们链接起来，如下所示：

doAsyncCall(..).flatMap { res1 =>
  doAsyncCall2(..).flatMap { res2 =>
    doAsyncCall3(..).map { res3 =>
      res
    }
  }
}

其可以分布在不同的函数调用中。现在，这些doAsyncCallX调用中的每一个都返回一个未来的[Result]，我希望能够合成这些结果，在链上传递它们，直到最后我可以返回链中所有结果的合成结果。

为此，我考虑让每个doAsyncCallX接收前一个结果的隐式参数，并将获得的结果与前一个相结合。问题是，我看不到一种不使用隐式VAL的方法来实现这一点，如下所示：

doAsyncCall(..).flatMap { res1 =>
  implicit val implicitRes1 = res1
  doAsyncCall2(..).flatMap { res2 =>
    implicit val implicitRes2 = res2
    doAsyncCall3(..).map { res3 =>
      res
    }
  }
}

我想做的是能够截获平面图的应用程序，以确保之前的响应作为下一个doAsyncCallX调用的隐式参数正确传递。关于如何完成此操作的任何想法？

Answer 1

也许我遗漏了什么，但是有理由使用隐含词吗？

for(res1 <- doAsyncCall1(..);
    res2 <- doAsyncCall2(res1);
    res3 <- doAsyncCall3(res2)) yield(res3)

如果您需要返回由多个中间结果组成的结果，请更改yield以产生不同的结果，可能是一个元组，如< code>yield((res1，res2，res3))。其结果类似于< code>Future[(Result1，Result2，Result3)]