akka - 如何在 Akka 中测试 Actor 未终止

Question

我正在尝试测试 Actor 是否被终止，我知道有一种方法可以使用 TestProbe 的 expectTerminated 来测试它是否被终止。

http://doc.akka.io/docs/akka/2.4.16/scala/testing.html#Watching_Other_Actors_from_Probes

但是有没有办法测试相反的情况？

谢谢 :)

更新

在我的场景中，我有一个用户 actor，它有一个或多个子 actor，当所有子 actor 都断开连接(终止)时，它会自行终止。

行为工作正常，但我的问题是我只能测试它没有 child 离开并自行终止的场景。我找不到正确的断言来检查它是否没有终止，如果它仍然有 child 。

这是一个简化的测试版本:

"Terminates itself if there are no connected clients" in {
  val userActor = system.ActorOf(UserActor.props())

  userActor ! UserActor.ClientDisconnected()

  val deathWatch = TestProbe()
  deathWatch.watch(userActor)
  deathWatch.expectTerminated(userActor, timeoutDuration)
}

"Not Terminates itself when there are still other clients connected" in {
  val userActor = system.ActorOf(UserActor.props())

  // Connecting a client
  userActor ! UserActor.ClientConnected(sessionId, accessToken)

  userActor ! UserActor.ClientDisconnected()

  // How can I test that userActor is not terminated?
}

Answer 1

从 testkit 中汲取灵感，您可以执行以下操作:

  import scala.concurrent.duration._
  import akka.testkit._

  def expectNoTerminated(target: ActorRef, max: FiniteDuration) {
    val o = receiveOne(max.dilated)

    if (o ne null)
      assert(o != Terminated(target), s"received Terminated message $o")
  }

这只会检查，如果您收到一条消息，它不是 Terminated ，因此它可能无法涵盖所有​​场景..