Method subscribe

src/react/observable.py:40–45

(self, observer)

        del self.observers[:]

    def subscribe(self, observer):
        if self.closed:
            observer.on_close()
            return

        self.observers.append(observer)

    def subscribe_on_close(self, callback, *args):
        self.subscribe(_CloseSubscriber(callback, *args))