akka: Bir aktörün durdurulduğunu test etme

Question

Bir aktörün akka içinde durup durmadığını test etme şeklini merak ediyorum. İşte şu an yaptığım şeye bir örnek; Endişeli olduğum için karmaşık yapıyorum.

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

Ayrı izleyici aktör kurtulmak ve sadece testProbe aktör doğrudan hedef aktör izleyebilirsiniz:

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

Akka test docs ilgili bölüm için here bakınız.