From b2ddd12e28c73fd3a6b84e79c08a31109de4f7de Mon Sep 17 00:00:00 2001
From: Roland Kuhn <rk@rkuhn.info>
Date: Fri, 28 Mar 2014 23:03:00 +0100
Subject: [PATCH] !str add test for Grouped

---
 .../scala/akka/stream/StreamGroupedSpec.scala | 28 +++++++++++++++++++
 1 file changed, 28 insertions(+)
 create mode 100644 akka-stream/src/test/scala/akka/stream/StreamGroupedSpec.scala

diff --git a/akka-stream/src/test/scala/akka/stream/StreamGroupedSpec.scala b/akka-stream/src/test/scala/akka/stream/StreamGroupedSpec.scala
new file mode 100644
index 0000000000..2f3df20bf3
--- /dev/null
+++ b/akka-stream/src/test/scala/akka/stream/StreamGroupedSpec.scala
@@ -0,0 +1,28 @@
+/**
+ * Copyright (C) 2014 Typesafe Inc. <http://www.typesafe.com>
+ */
+package akka.stream
+
+import akka.testkit.AkkaSpec
+import akka.stream.testkit.ScriptedTest
+import scala.collection.immutable
+import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+
+class StreamGroupedSpec extends AkkaSpec with ScriptedTest {
+
+  val genSettings = GeneratorSettings(
+    initialInputBufferSize = 2,
+    maximumInputBufferSize = 16,
+    initialFanOutBufferSize = 1,
+    maxFanOutBufferSize = 16)
+
+  "A Grouped" must {
+
+    "group" in {
+      def script = Script((1 to 20) map { _ ⇒ val x, y, z = random.nextInt(); Seq(x, y, z) -> Seq(immutable.Seq(x, y, z)) }: _*)
+      (1 to 50) foreach (_ ⇒ runScript(script, genSettings)(_.grouped(3)))
+    }
+
+  }
+
+}
\ No newline at end of file