Wie man eine Asynchron-Funktion mehrmals nacheinander, bis der erste Erfolg auszuführen

Question

Sagen wir, ich habe eine Funktion

def request(url: String): Future[String] 

und brauchen eine Funktion

def requestFirst(urls: List[String]): Future[String] 

zu schreiben, die Anfrage ruft (url) in Sequenz, bis sie erfolgreich abgeschlossen wird (in diesem Fall wird der erfolgreiche Wert zurückgegeben) oder Anforderungen für alle URLs fehlschlagen (in diesem Fall werden alle Fehler zurückgegeben).

Wie kann dies in Scala getan werden?

Answer 1

def requestFirst(urls: List[String]): Future[String] = { 
    val default: Future[String] = Future.failed(new scala.Exception("all failed")) 
    urls.foldLeft(default)((prevFuture, currentUrl) => { 
    prevFuture fallbackTo (request(currentUrl)) 
    }) 
} 

ODER

def requestFirst(urls: List[String]): Future[String] = { 
    def requestFirstInternal(urlSubset: List[String]): Future[String] = { 
    if(urlSubset.isEmpty) { 
     Future.failed(new Exception("Exhausted all urlSubset")) 
    } else { 
     request(urlSubset.head) fallbackTo { 
     requestFirstInternal(urlSubset.tail) 
     } 
    } 
    } 
    requestFirstInternal(urls) 
} 

Answer 2

Dies ist, was ich mit basierend auf @ kam parnav-Shukla beantworten:

def requestFirst(urls: List[String]): Future[String] = { 
    def requestFirstInternal(urlSubset: List[String], errors: Seq[String]): Future[String] = { 
    if(urlSubset.isEmpty) { 
     Future.failed(new Exception(errors.mkString("\n"))) 
    } else { 
     request(urlSubset.head) recoverWith { t => 
     requestFirstInternal(urlSubset.tail, errors ++ Seq(t.getMessage)) 
     } 
    } 
    } 
    requestFirstInternal(urls, Seq.empty) 
}