node.js through stream that emits a unique stream of objects based on criteria - View it on GitHub