[incubator-pekko] branch main updated: =str Update FlowMergeAllSpec because the merge order is undefined. (#3)

[fa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git


The following commit(s) were added to refs/heads/main by this push:
     new a4e5df5e9c =str Update FlowMergeAllSpec because the merge order is undefined. (#3)
a4e5df5e9c is described below

commit a4e5df5e9c7355aad23acfadddc2d4f53947c9bf
Author: kerr <he...@gmail.com>
AuthorDate: Sun Nov 6 01:00:36 2022 +0800

    =str Update FlowMergeAllSpec because the merge order is undefined. (#3)
---
 .../src/test/scala/akka/stream/scaladsl/FlowMergeAllSpec.scala        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMergeAllSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMergeAllSpec.scala
index d93a37a7ab..48783b9ed4 100644
--- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMergeAllSpec.scala
+++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMergeAllSpec.scala
@@ -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))


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org