Еще одна scala Futures composition puzzler

Question

Я переношу код из синхронного в асинхронный. Проблема довольно проста: вызовите ряд функций и остановитесь с первым, чтобы вернуть результат без ошибок (возвращая это значение, в противном случае - последнее вычисленное значение). Я начал с:

def find(fs: Seq[Function0[Int]], result: Int = -1): Int = { 
    if (fs.isEmpty) result 
    else { 
    val res = fs.head() 
    if (res != 0) res 
    else find(fs.tail, res) 
    } 
} 

Однако, если функции становятся асинхронной (т.е. вернуть будущее [Int]) Я не могу получить правильный вызов. Например,

def ffind(ffs: Seq[Function0[Future[Int]]], result: Future[Int] = Future { -1 }): Future[Int] = { 
    if (ffs.isEmpty) result 
    else ffind(ffs.tail, ffs.head()) 
} 

отлично работает, но оценивает все функции независимо от возвращаемого значения. Но что-то вроде:

def findBad(ffs: Seq[Function0[Future[Int]]], result: Future[Int] = Future { -1 }): Future[Int] = { 
    if (ffs.isEmpty) result 
    else { 
     ffs.head() map { res => 
     if (res != 0) res 
     else findBad(ffs.tail, Future(res)) 
     } 
    } 
} 

не входит. Какие-либо предложения? Мы можем предположить, что каждый вызов функции дорог, поэтому никто не должен вызываться дважды, ни после первого «успешного» вызова в последовательности. TIA

Answer 1

Вот почему это не тип-чек: findBad возвращает Future[Int], но отображение res в вызове findBad приведет к Future[Future[Int]]. Вы должны изменить map на flatMap. Обратите внимание, что теперь вам также необходимо обернуть res из первого условия (если res! = 0) в Future, чтобы обе ветви вернули Future. Вот код:

ffs.head() flatMap { res => 
    if (res != 0) Future.succesful(res) 
    else findBad(ffs.tail, Future(res)) 
} 

BTW, если вы хотите запустить их все и вернуться в зависимости от того завершает первый, игнорируя все остальное, то это немного другая проблема (см here), но вы говорите, что каждый вызов функции дорого поэтому я сомневаюсь, что это то, что вы пытаетесь сделать.