使用Specs2测试Akka

Question

我有以下specs2测试:

package concurrent

import akka.actor.{Props, actorRef2Scala}
import akka.testkit.TestActorRef

import scala.concurrent.duration._

class MessageCoordinatingActorSpec extends ActorBaseSpec {

  "MessageCoordinatingActor" should {
    "receive a Result and update the related token and status" in {
      val (repositoryActorProbe, messageCoordinatingActorRef) = buildMockMessageCoordinatingActor


      val addresses = MockSession.getTestAddressesWithServicesAt(
                                   "16 Main Street", List("Service1", "Service2"))
      val postCode = Postcode("NE28 9QR", addresses)

      val matchedAddr = addresses.find(_.addrToken=="16 Main Street")


      messageCoordinatingActorRef ! Result(LookupResult(
        LookupStatus.ServicesAvailable, postCode, matchedAddr, true), testRecord)

      //Expect message to persist the virgin postcode record
      repositoryActorProbe.expectMsg(pairLongToDuration(3, SECONDS),
        PersistPostcode(postCode))

      1 mustEqual 1
    }
  }
}

abstract class ActorBaseSpec extends TestKit(ActorSystem("test")) with ImplicitSender with MustMatchers with SpecificationLike with Mockito {
    //This class just contains some fixture factory methods 
    //such as buildMockMessageCoordinatingActor
}

测试的内容对我的问题来说非常不重要,但我有两个问题.首先注意我必须使用

pairLongToDuration(3, SECONDS)

我希望能够使用

3.seconds (from the scala.concurrent.duration package)

但是当我这样做时,我收到以下错误:

[error]  found   : org.specs2.time.Duration
[error]  required: scala.concurrent.duration.FiniteDuration

知道如何解决这个问题吗？

还要注意我必须坚持下去

1 mustEqual 1

在底部.如果我拿出来,我得到

[error] /Users/.../MessageCoordinatingActorSpec.scala:18: could not find implicit value for evidence parameter of type org.specs2.execute.AsResult[concurrent.RepositoryActor.UpdateAddrToken]

似乎specs2不认可probe.expectMsg成功测试成功,有没有办法以更令人满意的方式解决这个问题？

干杯! NFV

Answer 1

您需要org.specs2.time.NoTimeConversions在持续时间问题中混合特征.

然后,您可以为AsResult[UpdateAddrToken]类型类创建一个隐式实例:

implicit def tokenAsResult = new AsResult[UpdateAddrToken] {
  def asResult(r: =>UpdateAddrToken) = success
}