0

我正在学习 Akka 演员模型中的测试方法。我试图从 Akka 文档中运行一些代码。当我运行以下代码时，会出现一个令人困惑的错误。我正在使用 JDK 1.8.121、macOS 和 Scala 2.12。

Akka 文档中的代码：

val probe = TestProbe()
val future = probe.ref ? "hello"
probe.expectMsg(0 millis, "hello") // TestActor runs on CallingThreadDispatcher
probe.reply("world")
assert(future.isCompleted && future.value == Some(Success("world")))

我在自己的电脑上设置了测试：

package TestKitDemo

import akka.actor.ActorSystem
import akka.actor.Status.Success
import akka.testkit.{TestKit, TestProbe}
import org.scalatest.{BeforeAndAfterAll, WordSpecLike}
import akka.pattern.ask
import akka.util.Timeout

import scala.concurrent.duration._
import scala.util.Try

class ReplyDemo extends TestKit(ActorSystem("Testsystem")) with WordSpecLike
with BeforeAndAfterAll{
//  import system.dispatcher
  override protected def afterAll(): Unit = {
    shutdown(system)
  }

  implicit val timeout = Timeout(2 seconds)
  "reply" should {
    "same" in {

      val probe = TestProbe()
      val future = probe.ref ? "hello"
      probe.expectMsg(0 millis, "hello") // TestActor runs on CallingThreadDispatcher
      probe.reply("world")


      // error
      assert(future.isCompleted && future.value == Some(Success("world")))

      // correct
//      assert(future.isCompleted && future.value.get == Try("world"))

    }
  }
}

我使用两种assert：一种是Akka文档中的代码，另一种是我自己使用的相等性测试Try。

我对是什么有一个想法Try。据我所知，Try是一种可以是Success或的类型Failure。

测试错误如下：

future.isCompleted was true, but Some(Success("world")) did not equal Some(Success(world))
ScalaTestFailureLocation: TestKitDemo.ReplyDemo at (ReplyDemo.scala:44)
Expected :Some(Success(world))
Actual   :future.isCompleted was true, but Some(Success("world"))

Some(Success("world"))不等于Some(Success(world))。怎么了？他们应该是平等的。

4

1 回答 1

0 
assert(future.isCompleted && future.value == Some(Success("world")))

上述断言在您的测试中失败的原因是因为您尝试匹配 onakka.actor.Status.Success而不是scala.util.Success. 代替

import akka.actor.Status.Success

和

import scala.util.Success

你的测试就会通过。

于 2017-10-24T00:59:51.833 回答