niedopasowanie typu; found: scala.concurrent.Future [play.api.libs.ws.Response] wymagany: play.api.libs.ws.Response

Question

Próbuję wysłać prośbę o dodanie do aplikacji Pusher, ale mam problem ze zwróceniem prawidłowy typ, niedopasowanie typu; znaleziono: scala.concurrent.Future [play.api.libs.ws.Response] wymagane: play.api.libs.ws.Response

def trigger(channel:String, event:String, message:String): ws.Response = { 
val domain = "api.pusherapp.com" 
val url = "/apps/"+appId+"/channels/"+channel+"/events"; 
val body = message 

val params = List( 
    ("auth_key", key), 
    ("auth_timestamp", (new Date().getTime()/1000) toInt), 
    ("auth_version", "1.0"), 
    ("name", event), 
    ("body_md5", md5(body)) 
).sortWith((a,b) => a._1 < b._1).map(o => o._1+"="+URLEncoder.encode(o._2.toString)).mkString("&"); 

    val signature = sha256(List("POST", url, params).mkString("\n"), secret.get); 
    val signatureEncoded = URLEncoder.encode(signature, "UTF-8"); 
    implicit val timeout = Timeout(5 seconds) 
    WS.url("http://"+domain+url+"?"+params+"&auth_signature="+signatureEncoded).post(body 
} 

Answer 1

Żądanie robisz z post jest asynchroniczny. To wywołanie natychmiast zwraca, ale nie zwraca obiektu Response. Zamiast tego zwraca obiekt Future[Response], który będzie zawierał obiekt Response po zakończeniu asynchronicznego żądania http.

Jeśli chcesz zablokować wykonanie aż wniosek zostanie zakończona, wykonaj następujące czynności:

val f = Ws.url(...).post(...) 
Await.result(f) 

Zobacz więcej na temat futures here.

Answer 2

Wystarczy dołączyć map:

WS.url("http://"+domain+url+"?"+params+"&auth_signature="+signatureEncoded).post(body).map(_) 

Answer 3

Zakładając, że nie chcesz tworzyć aplikacji blokującej, twoja metoda powinna również zwrócić wartość Future[ws.Response]. Niech twoja przyszłość spieprzy się z kontrolerem, gdzie zwrócisz AsyncResult używając Async { ... } i pozwól Playowi zająć się resztą.

Controller

def webServiceResult = Action { implicit request => 
    Async { 
    // ... your logic 
    trigger(channel, event, message).map { response => 
     // Do something with the response, e.g. convert to Json 
    } 
    } 
}