akka: làm thế nào để kiểm tra rằng một diễn viên đã được dừng lại

Question

Tôi tự hỏi cách kinh điển là thử nghiệm xem một diễn viên đã dừng lại trong akka. Đây là một ví dụ về cách tôi hiện đang làm; Tôi lo rằng tôi sẽ làm phức tạp hơn.

import akka.actor.{Terminated, Actor, Props, ActorSystem} 
import akka.testkit.TestProbe 

class MyActor extends Actor { 
    import MyActor._ 
    override def receive: Receive = { 
    case Stop => context.stop(self) 
    } 
} 

object MyActor { 
    def props = Props(new MyActor) 
    case object Stop 
} 


object MyActorSpec { 

    val system = ActorSystem() 
    val myActor = system.actorOf(MyActor.props) 
    val testProbe = TestProbe() 

    case object MyActorStopped 

    val watcher = system.actorOf(Props(new Actor { 
    context.watch(myActor) 
    override def receive: Actor.Receive = { 
     case Terminated(`myActor`) => testProbe.ref ! MyActorStopped 
    } 
    })) 

    myActor ! MyActor.Stop 
    testProbe.expectMsg(MyActorStopped) 
} 

Answer 1

Bạn có thể thoát khỏi những diễn viên watcher riêng biệt, và chỉ cần xem các diễn viên mục tiêu trực tiếp từ các diễn viên testProbe:

val testProbe = TestProbe() 
testProbe watch myActor 
myActor ! MyActor.Stop 
testProbe.expectTerminated(myActor) 

Xem here cho phần có liên quan của các tài liệu thử nghiệm Akka.