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 4b0195ab5d..222439d2b6 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 @@ -143,6 +143,14 @@ object TestPublisher { self } + /** + * Expect no messages. + */ + def expectNoMessage(): Self = executeAfterSubscription { + probe.expectNoMessage() + self + } + /** * Expect no messages for a given duration. */