akka: jak sprawdzić, czy aktor został zatrzymany

Question

Zastanawiam się, jaki jest kanoniczny sposób testowania, czy aktor zatrzymał się w akka. Oto przykład tego, jak obecnie się zajmuję; Martwię się, że to komplikuję.

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

można pozbyć odrębnej aktora obserwatora, i po prostu oglądać aktora docelowego bezpośrednio z testProbe aktora:

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

Zobacz here do odpowiedniej sekcji testów docs Akka.