asynchronous - 从喷雾响应中访问喷雾请求

Question

我每 50 毫秒调用一次这个函数：

def send() = {
    val myData = generateRandomData()
    val response = pipeline(Post("http://slow-website.com/send", myData))
    response onComplete {
      case Success(r) => ? how to access myData  ?

      case Failure(error) => print(error.getMessage)
    }
}

我想知道我的成功请求中发送了哪些数据。
我怎样才能做到这一点？

Answer 1

只是参考myData。

幕后发生的事情是 Scala 编译器为onComplete处理程序参数创建了一个闭包，该闭包捕获对的引用，myData以便您可以使用它。