File tree 2 files changed +7
-5
lines changed
2 files changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -302,12 +302,13 @@ def defer(
302
302
---1--2--3--|
303
303
304
304
Example:
305
- >>> res = reactivex.defer(lambda: of(1, 2, 3))
305
+ >>> res = reactivex.defer(lambda scheduler : of(1, 2, 3))
306
306
307
307
Args:
308
308
factory: Observable factory function to invoke for each observer
309
- which invokes :func:`subscribe() <reactivex.Observable.subscribe>` on
310
- the resulting sequence.
309
+ which invokes :func:`subscribe()
310
+ <reactivex.Observable.subscribe>` on the resulting sequence.
311
+ The factory takes a single argument, the scheduler used.
311
312
312
313
Returns:
313
314
An observable sequence whose observers trigger an invocation
Original file line number Diff line number Diff line change @@ -14,11 +14,12 @@ def defer_(
14
14
function whenever a new observer subscribes.
15
15
16
16
Example:
17
- >>> res = defer(lambda: of(1, 2, 3))
17
+ >>> res = defer(lambda scheduler : of(1, 2, 3))
18
18
19
19
Args:
20
20
observable_factory: Observable factory function to invoke for
21
- each observer that subscribes to the resulting sequence.
21
+ each observer that subscribes to the resulting sequence. The
22
+ factory takes a single argument, the scheduler used.
22
23
23
24
Returns:
24
25
An observable sequence whose observers trigger an invocation
You can’t perform that action at this time.
0 commit comments