rx/core/observablebase.py
def concat_map(self, mapper: Callable[[Any], Any]) -> 'ObservableBase':
        """Maps each emission to an Observable and fires its emissions.
        It will only fire each resulting Observable sequentially.
        The next derived Observable will not start its emissions until
        the current one calls close
        """
        return self.map(mapper).concat_all()
Maps each emission to an Observable and fires its emissions.
        It will only fire each resulting Observable sequentially.
        The next derived Observable will not start its emissions until
        the current one calls close
        
Maps each emission to an Observable and fires its emissions.
It will only fire each resulting Observable sequentially.
The next derived Observable will not start its emissions until
the current one calls close
Maps each emission to an Observable and fires its emissions . It will only fire each resulting Observable sequentially . The next derived Observable will not start its emissions until the current one calls close
def concat_map(self, mapper: Callable[[Any], Any]) -> 'ObservableBase':
        return self.map(mapper).concat_all()
def concat_map ( self , mapper : Callable [ [ Any ] , Any ] ) -> 'ObservableBase' : return self . map ( mapper ) . concat_all ( )
Maps each emission to an Observable and fires its emissions.
Maps each emission to an Observable and fires its emissions .
"""Maps each emission to an Observable and fires its emissions.
        It will only fire each resulting Observable sequentially.
        The next derived Observable will not start its emissions until
        the current one calls close
        """
self
mapper
Callable[[Any], Any]