flatMap?

[wilsonjackson]

It seems like this module could use a flatMap implementation. I've even looked for it in other modules, and can't seem to find a flatMap for node streams (which seems crazy!), only libraries like bacon.js and highland which use their own stream types.

Would you entertain a PR adding flatMap?

[devinus]

I actually need this right now. Unsure how to continue...

[devinus]

For people finding this in the future, I accomplished a "flatMap" by using this:

        .pipe(es.through(function(data) {
          var stream = this;
          data.forEach(function(r) {
            stream.emit('data', r);
          });
        }))

[dominictarr]

@devinus it would be better to do steam.queue(data) instead of stream.emit('data', data)` because then back pause will work correctly.

[devinus]

@dominictarr Interesting. Would you accept a flatMap patch using this functionality?

[devinus]

I wonder why mapSync uses emit rather than queue.

[dominictarr]

@devinus ah, it's probably just old. I don't use this module anymore, i now use https://github.com/dominictarr/pull-stream

If you publish a flatMap module and then make a pr to include it, i'll merge.