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

More generous binding timeouts in TcpSpec (#21246)

Browse source 
* More generous binding timeouts in TcpSpec #21014

* Use remainingOrDefault instead
This commit is contained in:
Johan Andrén 2016-08-23 10:50:25 +02:00 • committed by Konrad Malawski
parent 640f35ec64
commit e480b7940e
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream-tests/src/test/scala/akka/stream/io/TcpSpec.scala
View file

@ -430,7 +430,7 @@ class TcpSpec extends StreamSpec("akka.stream.materializer.subscription-timeout.
.run()
// make sure that the server has bound to the socket
val binding = Await.result(bindingFuture, 100.millis)
val binding = Await.result(bindingFuture, remainingOrDefault)
val testInput = (0 to 255).map(ByteString(_))
val expectedOutput = ByteString(Array.tabulate(256)(_.asInstanceOf[Byte]))
@ -451,7 +451,7 @@ class TcpSpec extends StreamSpec("akka.stream.materializer.subscription-timeout.
.run()
// make sure that the server has bound to the socket
val binding = Await.result(bindingFuture, 100.millis)
val binding = Await.result(bindingFuture, remainingOrDefault)
val echoConnection = Tcp().outgoingConnection(serverAddress)
@ -555,7 +555,7 @@ class TcpSpec extends StreamSpec("akka.stream.materializer.subscription-timeout.
val bindingFuture = Tcp().bindAndHandle(Flow[ByteString], address.getHostName, address.getPort)(mat2)
// Ensure server is running
Await.ready(bindingFuture, 3.seconds)
Await.ready(bindingFuture, remainingOrDefault)
// and is possible to communicate with
Await.result(
Source.single(ByteString(0)).via(Tcp().outgoingConnection(address)).runWith(Sink.ignore),