diff --git a/reactivex/operators/_subscribeon.py b/reactivex/operators/_subscribeon.py
index f1191007..4eab5a6e 100644
--- 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)