raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Doing a roundtrip before issuing the wave of messages

Browse source
This commit is contained in:
Viktor Klang 2012-06-20 14:43:11 +02:00
parent 28ee78bfd5
commit 8fcffcab00
1 changed files with 10 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

14
akka-remote/src/test/scala/akka/remote/Ticket1978CommunicationSpec.scala
View file

@ -121,20 +121,26 @@ abstract class Ticket1978CommunicationSpec(val cipherConfig: CipherConfig) exten
}
}
("- SSL communication") must {
("-") must {
if (cipherConfig.runTest) {
val ignoreMe = other.actorOf(Props(new Actor { def receive = { case ("ping", x) ⇒ sender ! ((("pong", x), sender)) } }), "echo")
val otherAddress = other.asInstanceOf[ExtendedActorSystem].provider.asInstanceOf[RemoteActorRefProvider].transport.address
"support tell" in {
val here = system.actorFor(otherAddress.toString + "/user/echo")
for (i ← 1 to 1000) here ! (("ping", i))
for (i ← 1 to 1000) expectMsgPF(timeout.duration) { case (("pong", i), `testActor`) ⇒ true }
Await.result(here ? (("ping", -1)) mapTo manifest[((String, Int), ActorRef)], timeout.duration)._1 must be(("pong", -1))
for (i ← 1 to 10000) here ! (("ping", i))
for (i ← 1 to 10000) expectMsgPF(timeout.duration) { case (("pong", i), `testActor`) ⇒ true }
}
"support ask" in {
val here = system.actorFor(otherAddress.toString + "/user/echo")
val f = for (i ← 1 to 1000) yield here ? (("ping", i)) mapTo manifest[((String, Int), ActorRef)]
Await.result(here ? (("ping", -1)) mapTo manifest[((String, Int), ActorRef)], timeout.duration)._1 must be(("pong", -1))
val f = for (i ← 1 to 10000) yield here ? (("ping", i)) mapTo manifest[((String, Int), ActorRef)]
Await.result(Future.sequence(f), timeout.duration).map(_._1._1).toSet must be(Set("pong"))
}