Defer opening of streams and queue them using queue-async
more fluent interface:
i) from: provides 'pipeline.from', which provides all sources available to read from, ex: pipeline.from.mongo
ii) to: provides 'pipeline.to', which provides all destinations available, ex: pipeline.to.file
iii) all stream modifiers like, map, stringify, split can be accessed straightaway from pipeline, ex: pipeline.stringify

ex: pipeline.from.mongo(.. params ..).stringify().to.file(.. params ..)
Merge branch 'master' of https://github.com/gitcloneashish/pipe
some init changes