Parsing CSV with writeable buffer

csvtest.js

const request = require('request')
const stream = require('stream')
const buffer = require('buffer') 
class CSVStream extends stream.Writable {
  constructor() {
    super()
    this._count = 0
    this._buff = ""
    this._push = (x) => {
      //TODO figure out whether to dedup here or on DB Side
      //TODO Push to DB or Kinesis
      console.log(x)
    }
  }
  _write(chunk, enc, next) {
    var b = buffer.Buffer.from(chunk.toString(),'utf8')
    b.map((x) => {
      if(x == 10) { //nl
        this._push(this._buff)
        this._buff = ""
      } else {
        this._buff += String.fromCharCode(x)
      }
    })
    next()
  }
}
var test = () => {
  request('http://localhost:8888/test.csv').pipe(new CSVStream())
}
test()