Scala Future带有用于理解的过滤器

Question

在下面的示例中，我得到异常java.util.NoSuchElementException：Future.filter谓词不满足

当检查< code>if( i == 2 )失败时，我希望得到结果< code>Future( Test2 )。我如何在一个处理组合未来的for理解中处理filter/if？

下面是一个在Scala REPL中工作的简化示例。

代码：

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

当然，我自己想出了一个解决办法。也许有更好、更惯用的解决方案？

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 2

在中，为了理解，您通过i==2进行过滤。由于f1的值不是2，因此它不会产生成功，而是失败。正如您的error消息告诉您的那样，筛选器的谓词不满足。但是，f2.recover返回一个新的未来。f2的值未被操纵。它仍然存储故障。这就是调用＜code＞f2.value＜/code＞时出现错误消息的原因我能想到的唯一替代方法是在您的中使用else来理解，如下所示。

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

这将返回＜code＞一些（成功（Test2）），与＜code＞f3.值一样。

Answer 3

在我看来，这是一个更惯用的解决方案。此谓词函数创建包含异常的＜code＞未来[Unit]成功（“Test1”）或失败（“Test2”）。这与“Test1”和“Test2”略有不同，但我发现这种语法更有用。

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

你这样使用它：

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