streams fun

gistfile1.txt

var findit = require('findit')('./posts');
findit.on('file', function(file, stat) {
  (fs.createReadStream(file)).pipe(through(function(data) {
    this.queue(marked(data.toString()));
  })).pipe(process.stdout);
});

attempt to pipe contents onto index html

var rs = fs.createReadStream('./templates/index.html');
var tr = trumpet();
rs.pipe(tr);
var findit = require('findit')('./posts');
findit.on('file', function(file, stat) {
  (fs.createReadStream(file)).pipe(through(function(data) {
    this.queue(marked(data.toString()));
  })).pipe(tr.select('body').createStream()).pipe(process.stdout);
});

hmm.. still not the wanted output...

var duplexer = require('duplexer');
var rs = fs.createReadStream('./templates/index.html');
var tr = trumpet();

var indexStream = (function() {

  var input = concat(function(data) {
    output.queue(data.toString());
    output.queue(null);
  });
  var output = through();

  return duplexer(input, output);

})();

var findit = require('findit')('./posts');
findit.on('file', function(file, stat) {
  (fs.createReadStream(file)).pipe(through(function(data) {
    this.queue(marked(data.toString()));
  })).pipe(indexStream);
});