Merge 8f127b8 into 7211831

ReactiveX · Mar 5, 2022 · 226ecf6 · 226ecf6
2 parents 7211831 + 8f127b8
commit 226ecf6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git 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 = reactivex.defer(lambda scheduler: of(1, 2, 3))
 
     Args:
         factory: Observable factory function to invoke for each observer
-            which invokes :func:`subscribe() <reactivex.Observable.subscribe>` on
-            the resulting sequence.
+            which invokes :func:`subscribe()
+            <reactivex.Observable.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
@@ -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