add flat map

Author: 北川

index.js

@@ -8,6 +8,7 @@ var Stream = require('stream').Stream
   , es = exports
   , through = require('through')
   , from = require('from')
+  , flatmap = require('flatmap-stream')
   , duplex = require('duplexer')
   , map = require('map-stream')
   , pause = require('pause-stream')
@@ -18,6 +19,7 @@ var Stream = require('stream').Stream
 es.Stream = Stream //re-export Stream from core
 es.through = through
 es.from = from
+es.flatmap = flatmap
 es.duplex = duplex
 es.map = map
 es.pause = pause

package-lock.json

@@ -9,6 +9,7 @@
   },
   "dependencies": {
     "duplexer": "^0.1.1",
+    "flatmap-stream": "^0.1.0",
     "from": "^0.1.7",
     "map-stream": "0.0.7",
     "pause-stream": "^0.0.11",

package.json

@@ -0,0 +1,17 @@
+'use strict';
+
+var es = require('../')
+  , it = require('it-is')
+
+exports ['flatmap'] = function (test) {
+  es.readArray([[1], [1, 2], [1, 2, 3]])
+    .pipe(es.flatmap(function(e, cb) {
+      cb(null, e + 1)
+    }))
+    .pipe(es.writeArray(function(error, array) {
+      test.deepEqual([2, 2, 3, 2, 3, 4], array)
+      test.end()
+    }))
+}
+
+require('./helper')(module)