Scala Future z filtrem dla zrozumienia

Question

W poniższym przykładzie uzyskać wyjątkiem java.util.NoSuchElementException: Future.filter predicate is not satisfied

chcę mieć wynik Future(Test2) gdy kontrola if(i == 2) zawiedzie. Jak mogę obsłużyć filtr/czy w ramach rozumienia, które zajmuje się komponowaniem kontraktów terminowych?

Poniżej znajduje się uproszczony przykład, który działa w REPL Scala.

Kod:

import scala.concurrent.Future 
import scala.util.{ Try, Success, Failure } 
import scala.concurrent.ExecutionContext.Implicits.global 

val f1 = Future(1) 
val f2 = for { 
    i <- f1 
    if(i == 2) 
} yield "Test1" 
f2.recover{ case _ => "Test2" } 
f2.value 

Answer 1

W swojej for-comprehension, jesteś filtrując przez i == 2. Ponieważ wartość f1 nie jest równa dwóm, nie da się uzyskać Success, ale zamiast tego Failure. Predykat filtra nie jest spełniony, tak jak informuje Cię komunikat o błędzie. Jednak f2.recover zwraca nową Future. Wartość f2 nie jest modyfikowana. Wciąż przechowuje Failure. To jest powód, dla którego pojawi się komunikat o błędzie, gdy zadzwonisz pod numer f2.value.
Jedyną alternatywą, o której mogę pomyśleć, byłoby użycie else w twoim for-comprehension, jak pokazano here.

val f2 = for (i <- f1) yield { 
    if (i == 2) "Test1" 
    else "Test2" 
} 
f2.value 

ten powróci Some(Success(Test2)) jako swój f3.value robi.

Answer 2

Oczywiście, że zorientowali się jedno rozwiązanie siebie. Być może istnieją lepsze, bardziej idiomatyczne rozwiązania?

import scala.concurrent.Future 
import scala.util.{ Try, Success, Failure } 
import scala.concurrent.ExecutionContext.Implicits.global 

val f1 = Future(1) 
val f2 = for { 
    i <- f1 
    if(i == 2) 
} yield "Test1" 
val f3 = f2.recover{ case _ => "Test2" } 
// OR val f3 = f2.fallbackTo(Future("Test2")) 
f3.value 

Answer 3

Jest to bardziej idiomatyczne rozwiązanie, moim zdaniem. Ta funkcja predykatu tworzy albo Future[Unit] lub nieudaną przyszłość zawierającą wyjątek. Na przykład, spowoduje to albo Success("Test1") lub Failure(Exception("Test2")). To trochę różni się od "Test1" i "Test2", ale uważam tę składnię za bardziej użyteczną.

def predicate(condition: Boolean)(fail: Exception): Future[Unit] = 
    if (condition) Future(()) else Future.failed(fail) 

go używać tak:

val f2 = for { 
    i <- f1 
    _ <- predicate(i == 2)(new Exception("Test2")) 
    j <- f3 // f3 will only run if the predicate is true 
} yield "Test1"