Actor test helpers

TestActorHelpers.scala

import akka.testkit.TestActorRef

object TestActorHelpers {
  def queueMessagesTo(pausedActor: TestActorRef[Nothing])(sendMessages: => Unit) = {
    pausedActor.suspend()
    sendMessages
    pausedActor.resume(null)
  }
}

class UsageExample {
  def test() = {
    val actor = TestActorRef(Props(new MyActor()))

    queueMessagesTo(actor) {
      publisher ! "first"
      publisher ! "second" // maybe this triggers the actor to send itself PoisonPill
      publisher ! "third"
    }
  }
}