Rx module that creates an observable sequence from a VP PubSub events