Merge pull request #25353 from chbatey/issue-24956-streamtestkitspec

Harden StreamTestKitSpec
This commit is contained in:
Patrik Nordwall 2018-08-23 11:34:04 +02:00 committed by GitHub
commit 98a51e331c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -184,11 +184,12 @@ class StreamTestKitSpec extends AkkaSpec {
"#expectNextChainingPF should fail after timeout when element delayed" in {
intercept[AssertionError] {
val timeout = 100.millis
val overTimeout = timeout + (10.millis)
val overTimeout = timeout + 50.millis
Source.tick(overTimeout, 1.millis, 1).runWith(TestSink.probe)
.request(1)
.expectNextChainingPF(timeout, {
case 1
system.log.info("Message received :(")
})
}.getMessage should include("timeout")
}