Phone Calls | Loading Data: processing JSON

phone_calls_load_data_9b-2.js

function parseDataToObjects(input) {
  const items = [];
  return new Promise(function(resolve, reject) {
    const pipeline = chain([
      fs.createReadStream(input.dataPath + ".json"),
      parser(),
      streamArray()
    ]);

    pipeline.on("data", function(result) {
      items.push(result.value);
    });

    pipeline.on("end", function() {
      resolve(items);
    });
  });
}