Method subscribe

src/react/observable.py:205–207

(self, observer)

        self.source_closed = True

    def subscribe(self, observer):
        with self.subscriber_lock:
            super().subscribe(observer)

    def flush_buffer(self):
        while not self.closed: