Introducing the ConnectableObservable object