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

=str #19993 Less tight limits in one throttle test

Browse source
This commit is contained in:
Johan Andrén 2016-04-05 17:08:42 +02:00
parent b3c85512a3
commit b11eff984d
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowThrottleSpec.scala
View file

@ -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()
}