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

Nicer message when expectCancellation() fails (#23847)

Browse source
This commit is contained in:
Arnout Engelen 2017-10-25 02:14:21 +02:00 • committed by Konrad `ktoso` Malawski
parent 85ab0efbd8
commit b8a18bcf30
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
View file

@ -788,7 +788,7 @@ private[testkit] object StreamTestKit {
case RequestMore(sub, n) if sub eq this ⇒ n
}
def expectCancellation(): Unit = publisherProbe.fishForMessage() {
def expectCancellation(): Unit = publisherProbe.fishForMessage(hint = "Expecting cancellation") {
case CancelSubscription(sub) if sub eq this ⇒ true
case RequestMore(sub, _) if sub eq this ⇒ false
}