switch to combine-stream and filter duplicates