使用play和akka-https：如何正確鏈接多個請求到傳入的請求以創建響應？

Question

所以我試圖讓一個小型遊戲應用程序與另一個休息服務進行通信。 這個想法是，在玩家端接收請求，然後向其他api發出請求並將結果的一部分提供給另一個本地actor，然後顯示來自本地actor和其他服務在瀏覽器中的響應。 This image shows how

而我試圖用流做到這一點。我已經掌握了所有的工作，但是我對與我的當地演員談話並創建一個元組的部分感到絕不滿意，所以如果能夠指出我的方向，我會很高興，如何以優雅的方式做到這一點。乾淨的方式。

所以這裏是我的代碼。輸入是一個csv文件。 我的本地演員創建了一個我想放入響應的附加圖形。

def upload = Action.async(parse.multipartFormData) { request => 
request.body.file("input").map { inputCsv => 

//csv to list of strings 
val inputList: List[String] = convertFileToList(inputCsv) 

//http request to rest service 
val responseFuture: Future[HttpResponse] = httpRequest(inputList, "/path",4321 ,"0.0.0.0") 

//pattern match response and ask local actor 
val formattedResult = responseFuture.flatMap { response => 
    response.status match { 
    case akka.http.scaladsl.model.StatusCodes.OK => 
     val resultTeams = Unmarshal(response.entity).to[CustomResultCaseClass] 

    //the part I'd like to improve 
     val tupleFuture = resultTeams.map(result => 
     (Future(result.teams.reduce(_ + "," + _)), 
      plotter.ask(PlotData(result.eval)).mapTo[ChartPath].flatMap(plotAnswer => Future(plotAnswer.path)))) 
     tupleFuture.map(tuple => tuple._1.map(teams => 
     p._2.map(chartPath => Ok(views.html.upload(teams))(chartPath))))).flatMap(a => a).flatMap(b => b) 
    } 
} 
formattedResult 
}.getOrElse(Future(play.api.mvc.Results.BadRequest)) 
} 

Answer 1

For comprehensions是這種類型的使用情況下非常有用。

val teamFut = Future(result.teams.reduce(_ + "," + _)) 

//I think the final .flatMap(Future(_.path)) is unnecessary it should be 
// .map(_.path), but I wanted to replicate the question code functionality 
val pathFut = plotter.ask(PlotData(result.eval)) 
        .mapTo[ChartPath] 
        .flatMap(Future(_.path)) 

val okFut = 
    for { 
    teams  <- teamFut 
    chartPath <- pathFut  
    } yield Ok(views.html.upload(teams))(chartPath) 

注：這表明所涉及的重構一個基本的例子初始期貨應的外部實例化否則並行執行將不會發生。