From b8a18bcf30ec2734616b0aa8fde07b96046a8324 Mon Sep 17 00:00:00 2001
From: Arnout Engelen <github@bzzt.net>
Date: Wed, 25 Oct 2017 02:14:21 +0200
Subject: [PATCH] Nicer message when expectCancellation() fails (#23847)

---
 .../src/main/scala/akka/stream/testkit/StreamTestKit.scala      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala b/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
index 4717f10ba3..5e28c8c19a 100644
--- a/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
+++ b/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
@@ -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
     }