jeffbski/event-stream — pull request #1 by jeffbski (2011-11-02 19:19:28+00:00)
Title: allow Stream to be passed in as argument to pipeable

pipeable allows functions that return function or Stream to be
passed in as argument via setup().

Modified pipeable (setup()) so it also accepts Stream as well,
not needing to be a function that returns a Stream. This allows
us to use es.map, es.connect and any other Streams directly
without needing to wrap in a function.

Example:

var es = require('event-stream');

function decorate(data, cb) {
cb(null, 'decorated: ' + data);
}

es.pipeable(es.map(decorate));