def dispose(self):
        with self.lock:
            if not self.subject.is_disposed and self.observer:
                if self.subject.observers in self.observer:
                    self.subject.observers.remove(self.observer)
                self.observer = None
dataset/ETHPy150Open ReactiveX/RxPY/rx/subjects/innersubscription.py/InnerSubscription.dispose/swapped operands of `in`