Spike intercepting rx onNext