smoosh-stream

example.js

var flatten = require('.')
var bulk = require('bulk-write-stream')

var stream = bulk.obj(flatten(write))

function write(batch, cb) {
  batch.forEach(function(obj) {
    console.log(obj)
  })
  cb(null)
}

stream.write('first')
stream.write(['second', 'third'])
stream.write(['forth'])
stream.write('last')

// Prints:
// first
// second
// third
// forth
// last

index.js

module.exports = flatten

function flatten (write) {
  return function (batch, cb) {
    var flattened = []
    for (var i = 0; i < batch.length; i++) {
      var content = batch[i]
      if (Array.isArray(content)) {
        for (var j = 0; j < content.length; j++) {
          flattened.push(content[j])
        }
      } else {
        flattened.push(content)
      }
    }
    write(flattened, cb)
  }
}