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

Ignore unknown messages in LoggingReceiveSpec #23140

Browse source
This commit is contained in:
Johan Andrén 2017-06-13 15:37:17 +02:00 • committed by GitHub
parent e2e15b9298
commit 2393569df2
1 changed files with 9 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-actor-tests/src/test/scala/akka/event/LoggingReceiveSpec.scala
View file

@ -260,10 +260,15 @@ class LoggingReceiveSpec extends WordSpec with BeforeAndAfterAll {
Logging.Debug(sname, sclass, "stopped"))
}
// To get nice error messages I suppose we want to accept a set of PF's, but for now this'll do.
def expectMsgAllPF(messages: Int)(matchers: PartialFunction[AnyRef, _]) = {
val set = receiveWhile(messages = messages)(matchers).toSet
expectNoMsg(Duration.Zero)
def expectMsgAllPF(messages: Int)(matchers: PartialFunction[AnyRef, Int]) = {
def receiveNMatching(remaining: Int): Set[Int] =
if (remaining == 0) Set.empty
else {
val msg = receiveOne(remainingOrDefault)
if (matchers.isDefinedAt(msg)) receiveNMatching(remaining - 1) + matchers(msg)
else receiveNMatching(remaining) // unknown message, just ignore
}
val set = receiveNMatching(messages)
assert(set == (0 until messages).toSet)
}
}