ConnnectableObservable.swift

class ViewController: UIViewController {

    let disposeBag = DisposeBag()
    var prefetchMaster : ConnectableObservable<Int>!
  
    override func viewDidLoad() {
        super.viewDidLoad()
        prefetchMaster = Observable.interval(1, scheduler: MainScheduler.instance).publish()
        print("Published")
        let subscriber = prefetchMaster.subscribe{
            print("Next: \($0)")
        }
        prefetchMaster.connect()
        print("Connected")
        DispatchQueue.main.asyncAfter(deadline: .now() + 2) {
            print("Disposing after 3 seconds")
            subscriber.dispose()
        }
        DispatchQueue.main.asyncAfter(deadline: .now() + 6) {
            print("Subscribing again after 6 seconds")
            self.prefetchMaster.subscribe {
                print("Next: \($0)")
            }
        }
        
    }
 }