स्केला, नाटक, वायदा: कई वायदा से संयोजन परिणाम

Question

मैं उपयोग कर रहा हूँ:

• स्काला 2.10
• प्ले 2,1

वर्तमान में, मैं scala.concurrent._ से Future वर्ग का उपयोग कर रहा है, लेकिन मैं मैं एक और एपीआई कोशिश करने के लिए खुला हूँ।

मुझे एक सूची में कई वायदा के परिणामों को जोड़ने में परेशानी हो रही है [(स्ट्रिंग, स्ट्रिंग)]।

निम्नलिखित Controller विधि सफलतापूर्वक एक HTML टेम्पलेट के लिए एक एकल भविष्य के परिणाम देता है:

def test = Action { implicit request => 
    queryForm.bindFromRequest.fold(
     formWithErrors => Ok("Error!"), 
     query => { 
     Async { 
      getSearchResponse(query, 0).map { response => 
      Ok(views.html.form(queryForm, 
       getAuthors(response.body, List[(String, String)]()))) 
      } 
     } 
     }) 
    } 

विधि getSearchResult(String, Int) एक वेब सेवा API कॉल करता है और देता है एक भविष्य [play.api.libs.ws .Response]। विधि getAuthors(String, List[(String, String)]) HTML टेम्पलेट में एक सूची [(स्ट्रिंग, स्ट्रिंग)] देता है।

अब, मैं getSearchResult(String, Int) को for लूप में कई प्रतिक्रिया निकायों को प्राप्त करने की कोशिश कर रहा हूं। मुझे क्या करना है कोशिश कर रहा हूँ की एक विचार देना चाहिए निम्नलिखित है, लेकिन मैं एक संकलन समय त्रुटि मिलती है:

def test = Action { implicit request => 
    queryForm.bindFromRequest.fold(
     formWithErrors => Ok("Error!"), 
     query => { 
     Async { 
      val authors = for (i <- 0 to 100; if i % 10 == 0) yield { 
      getSearchResponse(query, i) 
      }.map { response => 
      getAuthors(response.body, List[(String, String)]()) 
      } 

      Ok(views.html.form(queryForm, authors)) 
     } 
     }) 
    } 

प्रकार मेल नहीं खाता; पाया: scala.collection.immutable.IndexedSeq [scala.concurrent.Future [सूची [(स्ट्रिंग, स्ट्रिंग)]]] की आवश्यकता: सूची [(स्ट्रिंग, स्ट्रिंग)]

मैं कैसे कई की प्रतिक्रियाओं मैप कर सकते हैं Future ऑब्जेक्ट्स को एक Result पर ऑब्जेक्ट्स?

Answer 1

किसी सूची या परिणाम प्रकार के अन्य संग्रह द्वारा भविष्य में पैरामीट्रिज्ड बनाएं।

here से:

प्ले 1 में आप यह कर सकते हैं:

F.Promise<List<WS.HttpResponse>> promises = F.Promise.waitAll(remoteCall1, remoteCall2, remoteCall3); 

    // where remoteCall1..3 are promises 

    List<WS.HttpResponse> httpResponses = await(promises); // request gets suspended here 

प्ले 2 कम प्रत्यक्ष में:

val httpResponses = for { 
    result1 <- remoteCall1 
    result2 <- remoteCall2 
} yield List(result1, result2)