Merge pull request #862 from axel22/issue/6052

SI-6052 - fix groupBy on parallel collections

1 files changed, 21 insertions, 0 deletions

diff --git a/test/files/run/t6052.scala b/test/files/run/t6052.scala
new file mode 100644
index 0000000000..385d5390d3
--- /dev/null
+++ b/test/files/run/t6052.scala
@@ -0,0 +1,21 @@
+
+
+
+
+
+
+
+object Test extends App {
+  def seqarr(i: Int) = Array[Int]() ++ (0 until i)
+  def pararr(i: Int) = seqarr(i).par
+  
+  def check[T](i: Int, f: Int => T) {
+    val gseq = seqarr(i).toSeq.groupBy(f)
+    val gpar = pararr(i).groupBy(f)
+    assert(gseq == gpar, (gseq, gpar))
+  }
+  
+  for (i <- 0 until 20) check(i, _ > 0)
+  for (i <- 0 until 20) check(i, _ % 2)
+  for (i <- 0 until 20) check(i, _ % 4)
+}