Added test for no grouping.

tests/test_demo.js

@@ -7,17 +7,17 @@ const {Transform} = require('stream');
 const Chain = require('../src/index');
 const {fromIterable} = require('../src/utils/FromIterable');
 
+const getTotalFromDatabaseByKey = async x =>
+new Promise(resolve => {
+  setTimeout(() => {
+    resolve(Math.min(x % 10, 3));
+  }, 20);
+});
+
 unit.add(module, [
   function test_demo(t) {
     const async = t.startAsync('test_demo');
 
-    const getTotalFromDatabaseByKey = async x =>
-      new Promise(resolve => {
-        setTimeout(() => {
-          resolve(Math.min(x % 10, 3));
-        }, 20);
-      });
-
     const chain = new Chain([
         // transforms a value
         x => x * x,
@@ -49,6 +49,42 @@ unit.add(module, [
       async.done();
     });
 
+    fromIterable([1, 2, 3]).pipe(chain);
+  },
+  function test_demoNoGrouping(t) {
+    const async = t.startAsync('test_demoNoGrouping');
+
+    const chain = new Chain([
+        // transforms a value
+        x => x * x,
+        // returns several values
+        x => Chain.many([x - 1, x, x + 1]),
+        // waits for an asynchronous operation
+        async x => await getTotalFromDatabaseByKey(x),
+        // returns multiple values with a generator
+        function* (x) {
+          for (let i = x; i > 0; --i) {
+            yield i;
+          }
+          return 0;
+        },
+        // filters out even values
+        x => (x % 2 ? x : null),
+        // uses an arbitrary transform stream
+        new Transform({
+          objectMode: true,
+          transform(x, _, callback) {
+            callback(null, x + 1);
+          }
+        })
+      ], {noGrouping: true}),
+      output = [];
+    chain.on('data', data => output.push(data));
+    chain.on('end', () => {
+      eval(t.TEST('t.unify(output, [2, 2, 4, 2, 4, 2, 4, 2, 4, 2, 4, 2])'));
+      async.done();
+    });
+
     fromIterable([1, 2, 3]).pipe(chain);
   }
 ]);