diff --git a/reactivex/operators/_timeout.py b/reactivex/operators/_timeout.py index da64cf319..70b1e9f63 100644 --- a/reactivex/operators/_timeout.py +++ b/reactivex/operators/_timeout.py @@ -9,10 +9,12 @@ SingleAssignmentDisposable, ) from reactivex.internal import curry_flip -from reactivex.scheduler import TimeoutScheduler +from reactivex.scheduler import EventLoopScheduler _T = TypeVar("_T") +_default_timeout_scheduler = EventLoopScheduler() + @curry_flip def timeout_( @@ -48,7 +50,7 @@ def subscribe( observer: abc.ObserverBase[_T], scheduler_: abc.SchedulerBase | None = None, ) -> abc.DisposableBase: - _scheduler = scheduler or scheduler_ or TimeoutScheduler.singleton() + _scheduler = scheduler or scheduler_ or _default_timeout_scheduler switched = [False] _id = [0]