Fix subscribe_on: forward the scheduler to the source.

jcafhe · jcafhe · commit 3d031947e94c · 2025-03-28T22:35:36.000+01:00
diff --git a/reactivex/operators/_subscribeon.py b/reactivex/operators/_subscribeon.py
@@ -43,7 +43,7 @@ def subscribe(
 
             def action(scheduler: abc.SchedulerBase, state: Optional[Any] = None):
                 d.disposable = ScheduledDisposable(
-                    scheduler, source.subscribe(observer)
+                    scheduler, source.subscribe(observer, scheduler=scheduler)
                 )
 
             m.disposable = scheduler.schedule(action)

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ def subscribe(`
`43`	`43`
`44`	`44`	`def action(scheduler: abc.SchedulerBase, state: Optional[Any] = None):`
`45`	`45`	`d.disposable = ScheduledDisposable(`
`46`		`- scheduler, source.subscribe(observer)`
	`46`	`+ scheduler, source.subscribe(observer, scheduler=scheduler)`
`47`	`47`	`)`
`48`	`48`
`49`	`49`	`m.disposable = scheduler.schedule(action)`