Filter a json file using streams

gistfile1.js

var es = require('event-stream');

es.pipeline(
  fs.createReadStream(ummon.config.log.path, {flags: 'r', encoding: 'utf-8'}),
  es.split(),
  es.parse(),
  es.mapSync(function (data) {
    if (key) {
      if (data[key] && data[key] === val) {
        return data;
      }
    } else {
      return data;
    }
  }),
  es.stringify(),
  res
);