node.js through stream that emits a unique stream of objects based on criteria