cocurrency

async.eachSeries(dirs, function(dir, callback) {
  converter         = new Converter({});
  var file          = __dirname + path + "/" + dir;
  converter.fromFile(file, function(err,csv) {
    var table = dir.replace(".csv", "").toLowerCase();
    var count = 0;
    async.mapLimit(csv, 100, function(rows, callbackMap) {
      r.db("baseball").table(table).insert(rows).then(function() {
        count = count + 100;
        console.log("Migrated",count,"rows");
        callbackMap();
      })
    })
  })
}, function() {
  console.log("All done!");
})