rx/core/observablebase.py
def delay_with_selector(self, subscription_delay=None, delay_duration_mapper=None
                           ) -> 'ObservableBase':
        """Time shifts the observable sequence based on a subscription
        delay and a delay mapper function for each element.

        Examples:
            # with mapper only
            >>> res = source.delay_with_selector(lambda x: Scheduler.timer(5000))
            # with delay and mapper
            >>> res = source.delay_with_selector(Observable.timer(2000), lambda x: Observable.timer(x))

        Args:
            subscription_delay: Sequence indicating the delay for the
                subscription to the source.
            delay_duration_mapper: Selector function to retrieve a
                sequence indicating the delay for each given element.

        Returns:
            Time-shifted observable sequence.
        """
        from ..operators.observable.delaywithselector import delay_with_selector
        return delay_with_selector(self, subscription_delay, delay_duration_mapper)
Time shifts the observable sequence based on a subscription
        delay and a delay mapper function for each element.

        Examples:
            # with mapper only
            >>> res = source.delay_with_selector(lambda x: Scheduler.timer(5000))
            # with delay and mapper
            >>> res = source.delay_with_selector(Observable.timer(2000), lambda x: Observable.timer(x))

        Args:
            subscription_delay: Sequence indicating the delay for the
                subscription to the source.
            delay_duration_mapper: Selector function to retrieve a
                sequence indicating the delay for each given element.

        Returns:
            Time-shifted observable sequence.
        
Time shifts the observable sequence based on a subscription
delay and a delay mapper function for each element.
Time shifts the observable sequence based on a subscription delay and a delay mapper function for each element .
def delay_with_selector(self, subscription_delay=None, delay_duration_mapper=None
                           ) -> 'ObservableBase':
        from ..operators.observable.delaywithselector import delay_with_selector
        return delay_with_selector(self, subscription_delay, delay_duration_mapper)
def delay_with_selector ( self , subscription_delay = None , delay_duration_mapper = None ) -> 'ObservableBase' : from . . operators . observable . delaywithselector import delay_with_selector return delay_with_selector ( self , subscription_delay , delay_duration_mapper )
Time shifts the observable sequence based on a subscription
delay and a delay mapper function for each element.
Time shifts the observable sequence based on a subscription delay and a delay mapper function for each element .
"""Time shifts the observable sequence based on a subscription
        delay and a delay mapper function for each element.

        Examples:
            # with mapper only
            >>> res = source.delay_with_selector(lambda x: Scheduler.timer(5000))
            # with delay and mapper
            >>> res = source.delay_with_selector(Observable.timer(2000), lambda x: Observable.timer(x))

        Args:
            subscription_delay: Sequence indicating the delay for the
                subscription to the source.
            delay_duration_mapper: Selector function to retrieve a
                sequence indicating the delay for each given element.

        Returns:
            Time-shifted observable sequence.
        """
Time-shifted observable sequence.
Time - shifted observable sequence .
self
subscription_delay
Sequence indicating the delay for the
subscription to the source.
Sequence indicating the delay for the subscription to the source .
delay_duration_mapper
Selector function to retrieve a
sequence indicating the delay for each given element.
Selector function to retrieve a sequence indicating the delay for each given element .
examples
with mapper only
>>> res = source.delay_with_selector(lambda x: Scheduler.timer(5000))
with delay and mapper
>>> res = source.delay_with_selector(Observable.timer(2000), lambda x: Observable.timer(x))
with mapper only >>> res = source . delay_with_selector ( lambda x : Scheduler . timer ( 5000 )) with delay and mapper >>> res = source . delay_with_selector ( Observable . timer ( 2000 ) lambda x : Observable . timer ( x ))