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

=str Update FlowMergeAllSpec because the merge order is undefined. (#3)

Browse source
This commit is contained in:
kerr 2022-11-06 01:00:36 +08:00 • committed by GitHub
parent 732f0890a0
commit a4e5df5e9c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -27,8 +27,8 @@ class FlowMergeAllSpec extends StreamSpec("""
"merge all elements of the first completed source to its downstream " in {
val source1 = Source(1 to 2)
val source2 = Source(3 to 6)
val source3 = Source(7 to 10)
val source2 = Source.repeat(3)
val source3 = Source.repeat(4)
val result =
source1.mergeAll(List(source2, source3), eagerComplete = true).runFold(Set.empty[Int])((set, i) => set + i)
result.futureValue should contain allElementsOf (Set(1, 2))