@@ -9,9 +9,7 @@ import scala.concurrent.{ Await, Future }
99import scala .concurrent .Promise
1010import scala .concurrent .duration ._
1111import scala .util .control .NoStackTrace
12-
1312import com .typesafe .config ._
14-
1513import akka .{ Done , NotUsed }
1614import akka .actor .{ Actor , ActorIdentity , ActorLogging , ActorRef , ActorSystem , ActorSystemImpl , Identify , Props }
1715import akka .actor .Status .Failure
@@ -23,6 +21,7 @@ import akka.stream.testkit.Utils.TE
2321import akka .stream .testkit .scaladsl ._
2422import akka .testkit .{ AkkaSpec , TestKit , TestProbe }
2523import akka .util .ByteString
24+ import org .scalatest .concurrent .Eventually
2625
2726object StreamRefsSpec {
2827
@@ -179,6 +178,7 @@ object StreamRefsSpec {
179178 }
180179 remote {
181180 artery.canonical.port = 0
181+ artery.canonical.hostname = localhost
182182 use-unsafe-remote-features-outside-cluster = on
183183 }
184184 }
@@ -195,7 +195,7 @@ object StreamRefsSpec {
195195 }
196196}
197197
198- class StreamRefsSpec extends AkkaSpec (StreamRefsSpec .config()) {
198+ class StreamRefsSpec extends AkkaSpec (StreamRefsSpec .config()) with Eventually {
199199 import StreamRefsSpec ._
200200
201201 val remoteSystem = ActorSystem (" RemoteSystem" , StreamRefsSpec .config())
0 commit comments