Тестирование играть взаимодействие контроллера с AKKA актера

Question

Моя пьеса приложение использует AKKA актера для обработки длительных вычислений:

class MyController(myActor : ActorRef) extends Controller{ 
    def doStuff = Action { implicit request => 

    val response : Future[Any] = myActor ? DoStuff 

    Async{ 
     response.map{   
     str : String => Ok(str) 
     } 
    } 
    } 
} 

Я пытаюсь проверить, что все работает должным образом. У меня есть отдельные тесты для проверки того, что актер ведет себя правильно и в основном просто хочет проверить, что контроллер отправляет правильные сообщения пользователю. Мой текущий подход вроде этого:

class MyControllerSpec extends Specification{ 
    "MyController" should { 

    object DummyActor extends Actor{ 
     def receive = { 
     case _ =>() 
     } 
    } 

    "do stuff properly" >> { 
     val probe = TestProbe()(Akka.system) 
     val test = new controllers.MyController(Akka.system.actorOf(Props(DummyActor)) 
     val result = test.doStuff(FakeRequest()) 
     probe.expectMsg(SomeMsg) 
    } 
    } 
} 

Контроллера посылает сообщение переданных в актере, когда действие DoStuff называется. Я пытаюсь проверить, отправлен ли правильный msg.

Я думаю, что test.doStuff запускается синхронно и время, когда фиктивный актер ничего не посылает. ОжиданиеMsg не запускается до тех пор, пока не будет возвращен вызов doStuff и уже отправлен SomeMsg. Как я могу решить эту проблему?

Answer 1

Это не то, что вы хотите передать зонд своему контроллеру, а не реализацию фиктивного актера, как бы что-то было отправлено на зонд, если нет?