Selectively consume events from Reactor