application-level sharding on node.js streams - View it on GitHub