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

Merge pull request #27848 from johanandren/wip-24580-GraphMergePrioritizedSpec-fail-fix

Browse source 
More tolerance in GraphMergePrioritizedSpec
This commit is contained in:
Patrik Nordwall 2019-10-09 17:31:03 +02:00 • committed by GitHub
commit 25ff48cca1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

18
akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergePrioritizedSpec.scala
View file

@ -63,19 +63,20 @@ class GraphMergePrioritizedSpec extends TwoStreamsSetup {
val subscription = probe.expectSubscription()
var collected = Seq.empty[Int]
val builder = Seq.newBuilder[Int]
for (_ <- 1 to elementCount) {
subscription.request(1)
collected :+= probe.expectNext()
builder += probe.expectNext()
}
val collected = builder.result()
val ones = collected.count(_ == 1).toDouble
val twos = collected.count(_ == 2).toDouble
val threes = collected.count(_ == 3).toDouble
(ones / twos).round shouldEqual 2
(ones / threes).round shouldEqual 6
(twos / threes).round shouldEqual 3
(ones / twos) should ===(2d +- 1)
(ones / threes) should ===(6d +- 1)
(twos / threes) should ===(3d +- 1)
}
"stream data when only one source produces" in {
@ -121,18 +122,19 @@ class GraphMergePrioritizedSpec extends TwoStreamsSetup {
val subscription = probe.expectSubscription()
var collected = Seq.empty[Int]
val builder = Vector.newBuilder[Int]
for (_ <- 1 to elementCount) {
subscription.request(1)
collected :+= probe.expectNext()
builder += probe.expectNext()
}
val collected = builder.result()
val ones = collected.count(_ == 1).toDouble
val twos = collected.count(_ == 2).toDouble
val threes = collected.count(_ == 3)
threes shouldEqual 0
(ones / twos).round shouldBe 2
(ones / twos) should ===(2d +- 1)
}
}