@extensionmethod(Observable)
def share(self):
    return self.publish().ref_count()
Share a single subscription among multple observers.
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/publish.py/share