From b11eff984dbc970da4d51b63dcbc6d03660e9674 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andre=CC=81n?= Date: Tue, 5 Apr 2016 17:08:42 +0200 Subject: [PATCH] =str #19993 Less tight limits in one throttle test --- .../scala/akka/stream/scaladsl/FlowThrottleSpec.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowThrottleSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowThrottleSpec.scala index 1d1b6cc133..2ff48f2883 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowThrottleSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowThrottleSpec.scala @@ -105,12 +105,12 @@ class FlowThrottleSpec extends AkkaSpec { } "send elements downstream as soon as time comes" in Utils.assertAllStagesStopped { - val probe = Source(1 to 10).throttle(2, 500.millis, 0, Shaping).runWith(TestSink.probe[Int]) + val probe = Source(1 to 10).throttle(2, 750.millis, 0, Shaping).runWith(TestSink.probe[Int]) .request(5) - probe.receiveWithin(600.millis) should be(Seq(1, 2)) - probe.expectNoMsg(100.millis) + probe.receiveWithin(900.millis) should be(Seq(1, 2)) + probe.expectNoMsg(150.millis) .expectNext(3) - .expectNoMsg(100.millis) + .expectNoMsg(150.millis) .expectNext(4) .cancel() }