Fixes deduping of streaming events.