diff --git a/reactivex/__init__.py b/reactivex/__init__.py index 8826c6a1b..14fff2cfa 100644 --- a/reactivex/__init__.py +++ b/reactivex/__init__.py @@ -302,12 +302,13 @@ def defer( ---1--2--3--| Example: - >>> res = reactivex.defer(lambda: of(1, 2, 3)) + >>> res = defer(lambda scheduler: of(1, 2, 3)) Args: factory: Observable factory function to invoke for each observer - which invokes :func:`subscribe() ` on - the resulting sequence. + which invokes :func:`subscribe() + ` on the resulting sequence. + The factory takes a single argument, the scheduler used. Returns: An observable sequence whose observers trigger an invocation diff --git a/reactivex/observable/defer.py b/reactivex/observable/defer.py index cbb4fd7f2..0a3407aa5 100644 --- a/reactivex/observable/defer.py +++ b/reactivex/observable/defer.py @@ -14,11 +14,12 @@ def defer_( function whenever a new observer subscribes. Example: - >>> res = defer(lambda: of(1, 2, 3)) + >>> res = defer(lambda scheduler: of(1, 2, 3)) Args: observable_factory: Observable factory function to invoke for - each observer that subscribes to the resulting sequence. + each observer that subscribes to the resulting sequence. The + factory takes a single argument, the scheduler used. Returns: An observable sequence whose observers trigger an invocation