Akka HTTP根据Future的结果设置响应头

cor*_*ota 2 rest scala akka akka-http

我正在使用Akka-HTTP 2.0-M2设计REST服务,并且遇到了我想要提供额外标头的情况,这些标头取决于所查询的Actor的回复.

目前,我有以下......

val route = {
  path("oncologist") {
    get {
      parameters('active.as[Boolean].?, 'skip.as[Int].?, 'limit.as[Int].?).as(GetAllOncologists) {
        req =>
          complete {
            (oncologistActor ? req).mapTo[OncologistList]
          }
      }
    }
  }
Run Code Online (Sandbox Code Playgroud)

虽然这是没有问题的回归.我想将OncologistList的一些属性移动到响应头中,而不是将它们返回到正文中.也就是说,我正在返回总记录数和偏移量,我想生成一个上一个和下一个URL头值供客户端使用.我对如何进行感到茫然.

cmb*_*ter 6

我认为你可以使用onCompleterespondWithHeaders指令来完成你想要的.该onComplete指令使用a的结果,Future这正是ask (?)将返回的结果.以下是使用case类的示例:

case class Foo(id:Int, name:String)
Run Code Online (Sandbox Code Playgroud)

一个简单的路线显示onComplete如下:

get{
  parameters('active.as[Boolean].?, 'skip.as[Int].?, 'limit.as[Int].?).as(GetAllOncologists) { req =>
    val fut = (oncologistActor ? req).mapTo[Foo]
    onComplete(fut){
      case util.Success(f) =>
        val headers = List(
          RawHeader("X-MyObject-Id", f.id.toString),
          RawHeader("X-MyObject-Name", f.name)
        )
        respondWithHeaders(headers){
          complete(StatusCodes.OK)
        }

      case util.Failure(ex) =>
        complete(StatusCodes.InternalServerError )
    }
  }
}
Run Code Online (Sandbox Code Playgroud)

因此,如果我们从askon 获得了成功的结果,那么oncologistActor我们可以利用它respondWithHeaders来为响应添加一些自定义标头.希望这是你想要的.