Transform a function into a pipeable writable stream in node/io.js - View it on GitHub