Parâmetro de conversão HTTP Scala Akka como java.time.ZonedDateTime
Estou trabalhando em um serviço REST usando o Akka HTTP (em Scala). Eu gostaria que um parâmetro que fosse passado para uma solicitação http get fosse convertido no tipo ZonedDateTime. O código funciona bem se eu tentar usar String ou Int, mas falhar com um tipo de ZonedDateTime. O código ficaria assim:
parameters('testparam.as[ZonedDateTime])
Aqui está o erro que estou vendo:
Error:(23, 35) type mismatch;
found : akka.http.scaladsl.common.NameReceptacle[java.time.ZonedDateTime]
required: akka.http.scaladsl.server.directives.ParameterDirectives.ParamMagnet
parameters('testparam.as[ZonedDateTime]){
Se adicionar mais de um parâmetro à lista, recebo um erro diferente:
Error:(23, 21) too many arguments for method parameters: (pdm: akka.http.scaladsl.server.directives.ParameterDirectives.ParamMagnet)pdm.Out
parameters('testparam.as[ZonedDateTime], 'testp2){
Encontrei isso na documentação quando estava pesquisando o problemahttp://doc.akka.io/japi/akka-stream-and-http-experimental/2.0/akka/http/scaladsl/server/directives/ParameterDirectives.html e tentei a solução alternativa de adicionarimport akka.http.scaladsl.server.directives.ParameterDirectives.ParamMagnet
juntamente com o uso do Scala 2.11, mas o problema persistiu.
Alguém poderia explicar o que estou fazendo de errado e por que o tipo ZonedDateTime não funciona? Desde já, obrigado!
Aqui está um trecho de código que deve reproduzir o problema que estou vendo
import java.time.ZonedDateTime
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer
import scala.io.StdIn
object WebServer {
def main(args: Array[String]) {
implicit val system = ActorSystem("my-system")
implicit val materializer = ActorMaterializer()
// needed for the future flatMap/onComplete in the end
implicit val executionContext = system.dispatcher
val route =
path("hello") {
get {
parameters('testparam.as[ZonedDateTime]){
(testparam) =>
complete(testparam.toString)
}
}
}
val bindingFuture = Http().bindAndHandle(route, "localhost", 8080)
println(s"Server online at http://localhost:8080/\nPress RETURN to stop...")
StdIn.readLine() // let it run until user presses return
bindingFuture
.flatMap(_.unbind()) // trigger unbinding from the port
.onComplete(_ => system.terminate()) // and shutdown when done
}
}