testing various streaming library

.gitignore

node_modules

csv_buf.js

var csvBuffStream = require('csv-multibuffer-stream');
var fs = require('fs');
var wstream = fs.createWriteStream('output');

var encoder = csvBuffStream()

fs.createReadStream('./test.csv').pipe(encoder).pipe(wstream);

multiplex.js

var multiplex = require('multiplex')
var plex1 = multiplex()
var stream1 = plex1.createStream()
var stream2 = plex1.createStream()

var plex2 = multiplex(function onStream(stream, id) {
  stream.on('data', function(c) {
    console.log('data', id, c.toString())
  })
})

plex1.pipe(plex2)

stream1.write(new Buffer('stream one!'))
stream2.write(new Buffer('stream two!'))

output

test1 test2 test3
1 2 3

test.csv