diff --git a/reactivex/operators/__init__.py b/reactivex/operators/__init__.py index 43a126fd..ca386880 100644 --- a/reactivex/operators/__init__.py +++ b/reactivex/operators/__init__.py @@ -685,7 +685,7 @@ def delay_with_mapper( Examples: >>> # with mapper only - >>> res = source.delay_with_mapper(lambda x: Scheduler.timer(5.0)) + >>> res = source.delay_with_mapper(lambda x: reactivex.timer(5.0)) >>> # with delay and mapper >>> res = source.delay_with_mapper( reactivex.timer(2.0), lambda x: reactivex.timer(x) @@ -3690,7 +3690,7 @@ def throttle_with_mapper( another value within a computed throttle duration. Example: - >>> op = throttle_with_mapper(lambda x: rx.Scheduler.timer(x+x)) + >>> op = throttle_with_mapper(lambda x: reactivex.timer(x+x)) Args: throttle_duration_mapper: Mapper function to retrieve an