through.js

const through = reuquire('through2')

getResponse((response) => {
  const mapper = through((chunk, enc, cb) => {
    let parsed
    
    try {
      parsed = JSON.parse(chunk.toString())
    } catch (err) {
      return cb(err)
    }

    // process parsed object
    const finished = process(parsed) 
    cb(null, finished)
  })
  mapper.cancel = () => {
    req.abort()
  }
  response.pipe(mapper)
  cb(null, mapper)  
})