Add more samples and fix split() example in README

README.md

@@ -110,7 +110,7 @@ Mhysa.fromArray(["a,b", "c,d"])
     .pipe(Mhysa.split(","))
     .pipe(Mhysa.join("|"))
     .pipe(process.stdout);
-// a|b|c|d is printed out
+// a|bc|d is printed out
 ```
 
 

samples/child.js

@@ -0,0 +1,6 @@
+const Mhysa = require("mhysa");
+const catProcess = require("child_process").exec("grep -o ab");
+
+Mhysa.fromArray(["a", "b", "c"])
+    .pipe(Mhysa.child(catProcess))
+    .pipe(process.stdout);

samples/concat.js

@@ -3,13 +3,10 @@ const Mhysa = require("mhysa");
 
 const source1 = new Readable();
 const source2 = new Readable();
-const expectedElements = ["a", "b", "c", "d"];
-let i = 0;
 Mhysa.concat(source1, source2).pipe(process.stdout);
-
+source1.push("a1 ");
-source1.push("a");
+source2.push("c3 ");
-source2.push("c");
+source1.push("b2 ");
-source1.push("b");
+source2.push("d4 ");
-source2.push("d");
 source1.push(null);
 source2.push(null);

samples/duplex.js

@@ -1,5 +1,6 @@
 const Mhysa = require("mhysa");
 const catProcess = require("child_process").exec("grep -o ab");
+
 Mhysa.fromArray(["a", "b", "c"])
     .pipe(Mhysa.duplex(catProcess.stdin, catProcess.stdout))
     .pipe(process.stdout);

samples/join.js

@@ -0,0 +1,5 @@
+const Mhysa = require("mhysa");
+
+Mhysa.fromArray(["a", "b", "c"])
+    .pipe(Mhysa.join(","))
+    .pipe(process.stdout);

samples/split.js

@@ -1,12 +1,6 @@
 const Mhysa = require("mhysa");
 
-const stream = Mhysa.split(",");
+Mhysa.fromArray(["a,b", "c,d"])
-const buf = Buffer.from("a,b,c");
+    .pipe(Mhysa.split(","))
-stream.on("data", function(data) {
+    .pipe(Mhysa.join("|"))
-    console.log(data);
+    .pipe(process.stdout);
-});
-
-for (let i = 0; i < buf.length; ++i) {
-    stream.write(buf.slice(i, i + 1));
-}
-stream.end();

yarn.lock

@@ -2060,7 +2060,7 @@ meow@^5.0.0:
     yargs-parser "^10.0.0"
 
 mhysa@./:
-  version "1.0.1"
+  version "1.0.2"
 
 micromatch@^3.1.10, micromatch@^3.1.4:
   version "3.1.10"