def on_next(self, value):
        self.observer.on_next(value)
        if value in self.dispose_on_map:
            self.dispose_on_map[value].dispose()
dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_publish.py/MySubject.on_next/original