Method subscribe

src/react/observable.py:117–121

(self, observer)

        super()._push(data)

    def subscribe(self, observer):
        for chunk in self.chunks:
            observer.on_next(chunk)

        super().subscribe(observer)

    def dispose(self):
        self._close()