diff --git a/akka-remote/src/test/scala/akka/remote/artery/LargeMessagesStreamSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/LargeMessagesStreamSpec.scala index 28973d065b..fd40c84e8a 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/LargeMessagesStreamSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/LargeMessagesStreamSpec.scala @@ -149,5 +149,9 @@ class LargeMessagesStreamSpec } } - def awaitResolve(selection: ActorSelection): ActorRef = Await.result(selection.resolveOne(3.seconds), 3.seconds) + def awaitResolve(selection: ActorSelection): ActorRef = { + awaitAssert { + Await.result(selection.resolveOne(1.second), 1.seconds) + } + } }