Method __init__

src/react/observable.py:142–145

(self, source_observable)

class _ReplayPipe(ReplayObservable):
    def __init__(self, source_observable):
        super().__init__()
        self.source = source_observable
        self.source.subscribe(self)

    def push(self, data: T):
        raise RuntimeError('Piped observable is read-only')