Method __init__

src/react/observable.py:168–172

(self, source_observable, map_function)

class _MappedPipe(PipedObservable):
    def __init__(self, source_observable, map_function):
        super().__init__(source_observable)

        self.map_function = map_function
        source_observable.subscribe(self)

    def on_next(self, data):
        mapped_data = self.map_function(data)