def map(self, mapper: Callable[[Any], Any]) -> 'Observable':
        r"""Map a function over an observable.

        Haskell: fmap f m = Cont $ \c -> runCont m (c . f)
        """
        source = self
        return Observable(lambda on_next: source.subscribe(compose(on_next, mapper)))
def map ( self , mapper : Callable [ [ Any ] , Any ] ) -> 'Observable' : source = self return Observable ( lambda on_next : source . subscribe ( compose ( on_next , mapper ) ) )
r"""Map a function over an observable.

        Haskell: fmap f m = Cont $ \c -> runCont m (c . f)