co-stream pipe example

gistfile1.js

function pipe(){
  var streams = [].slice.call(arguments);
  return streams.slice(1).reduce(function(acc, stream){
    return stream(acc);
  }, streams[0]);
}

// usage:

var read = pipe(a(), b(), c(), d());

// which is the same as:

var read = d(c(b(a())));