var mapLimited = require('map-stream-2-limited')
var transform = mapLimited(function (data, callback) {
  callback(null, data)
 
  // or
 
  callback(new Error('something failed'))
 
}, 10) // initial concurrency limit of 10
 
someStream
.pipe(transform)
 
// Modify concurrency limit by supplying a transform function
transform.changeLimit(function (limit) {
  return limit + 1 // Will throw if you attempt to change the limit to < 1
})