Чтение и модификация больших JSON файлов

      var getStream = function () {
         var jsonData = _projArr[i], //тут просто полный путь до файла 
             stream = fs.createReadStream(jsonData, {encoding: 'utf8'}),
             parser = JSONStream.parse('layers.*');
             return stream.pipe(parser);
      };
 
      getStream()
      .pipe(es.mapSync(function (data) {
        console.log(data); //по идее тут должна быть обработка найденных вариантов
        //т.е. я могу отправить эти данные в какую нибудь другую асинхронную функцию и там с ними работать
      }));

async function collectMohoProject(_path, _projArr){
//_path - новый путь
//_projArr - массив с путями до файлов JSON
   let fFolder = _path.substr(_path.lastIndexOf(_S)+1);
   for(let i = 0; i < _projArr.length; i++){
      let fName = _projArr[i].substr(_projArr[i].lastIndexOf(_S)+1);
      let newFile = _path + _S + fName;
      
      let getStream = function () {
         var jsonData = _projArr[i],
             stream = fs.createReadStream(jsonData, {encoding: 'utf8'}),
             parser = JSONStream.parse('layers.*');
             return stream.pipe(parser);
      };
 
      getStream()
      .pipe(es.mapSync(function (data) {
         console.log(data);
      }));
      
      console.log("до сюда доходит");
   }
}