Parse CSV into objects with RxJS

parse.js

const Rx = require('rx');
const csv = require('csv-parse');
const fs = require('fs');

Rx.Node.fromReadableStream(fs.createReadStream('file.csv').pipe(csv()))
  .skip(1)
  .withLatestFrom(rows.take(1), (row, header) => {
    // Map header[i] => row[i]  
    return row.reduce((rowObj, cell, i) => {
      rowObj[header[i]] = cell;
      return rowObj;
    }, {});
  })
  .subscribe((row) => {
    console.log("Row: %s", JSON.stringify(row, null, 2));
  });

@QuentinRow: That's very cool and it probably deserves its own gist. Where is getLogSubscriber used? Typo: csv('file.csv'), { columns: true })