Scala中期货的单元测试失败

Question

我试图在我正在编写的脚本中测试错误处理。如果异步函数fetchBar失败，我将模式匹配失败案例，然后返回包含失败结果的成功未来。

val fetchedBar = Try(fooClient.fetchBar(params))

fetchedBar match {
  case Success(bar) => foobar(bar)
  case Failure(e) => Future.successful(FooResult(success = false))
}

然而，当我对这个流进行单元测试时，我在测试失败案例时遇到了麻烦。我在fetchBar上打了一个存根，以返回失败的future，如下所示。

val fetchedBar = Try(Future.failed(new Exception()))

但是我注意到fetchedBar返回的是成功而不是失败。为什么会这样，我如何存根fetchBar函数来创建一个失败的尝试？

Answer 1

我认为你稍微混淆了概念——但这不完全是你的错。

事实是，Scala中的< code>Future是一个有点非正交的概念——事实上，它不仅代表延迟执行的概念，也代表失败的概念。

正因为如此，在大多数情况下，将未来包装到尝试中没有多大意义，反之亦然——除非有人想明确地将失败的概念与异步的概念分开。

换句话说，下面的组合有点奇怪，但仍然有其用途:

1. 尝试[Future[_]]-Future已经捕获了失败。但是，如果您有一个（行为不佳）库方法通常返回Future，但可能会抛出一个“同步”路径，则这是有意义的：

def futureReciprocal(i: Int): Float = { 
   val reciprocal = 1 / i // Division by zero is intentional
   Future.successful(reciprocal)
}

futureReciprocal(0) // throws
Try(futureReciprocal(0)) // Failure(DivisionByZero(...))

...但这基本上是修复实现不佳函数的一种变通方法

在你的情况下，你想做的是断言未来的结果。要做到这一点，实际上至少有两种选择。

< li >阻塞直到未来完成并检查结果-这通常是通过< code > Scala . concurrent . await :完成的

// writing this without the compiler, might mix up namespaces a bit
import scala.concurrent.Await
import scala.concurrent.duration.DurationInt

val future = fooClient.fetchBar(...)
val futureResult: Try[_] = Await.result(future, 1.second)
futureResult match { case Success(_) => ??? ; case Failure(exc) => ???; }

class YourTest extends FlatSpec with ScalaFutures {
   "fetchBar should return failed future" in {
        val future: Future[XYZ] = fooClient.fetchBar(...)
        // whenReady comes from the ScalaFutures trait
        whenReady(future) { result => result shouldBe XYZ } // asserting on the successful future result
        whenReady(future.failed) { exc => exc shoulBe a[RuntimeException] } // asserting on an exception in the failed future
   }
}