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

increase test timeout in FlowLimitSpec, #20197

Browse source 
* and a bunch of other 300.ms timeouts
This commit is contained in:
Patrik Nordwall 2016-04-05 15:57:47 +02:00
parent b3c85512a3
commit 6405991f86
8 changed files with 20 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSinkSpec.scala
View file

@ -40,7 +40,7 @@ class QueueSinkSpec extends AkkaSpec {
val sub = probe.expectSubscription()
val future = queue.pull()
val future2 = queue.pull()
an[IllegalStateException] shouldBe thrownBy { Await.result(future2, 300.millis) }
an[IllegalStateException] shouldBe thrownBy { Await.result(future2, remainingOrDefault) }
sub.sendNext(1)
future.pipeTo(testActor)
@ -82,7 +82,7 @@ class QueueSinkSpec extends AkkaSpec {
val sub = probe.expectSubscription()
sub.sendError(ex)
the[Exception] thrownBy { Await.result(queue.pull(), 300.millis) } should be(ex)
the[Exception] thrownBy { Await.result(queue.pull(), remainingOrDefault) } should be(ex)
}
"timeout future when stream cannot provide data" in assertAllStagesStopped {