From d9e33a4c17e90b814101460982e9697612a7492f Mon Sep 17 00:00:00 2001 From: Robert Mahfoud Date: Wed, 12 Nov 2025 17:00:24 -0800 Subject: [PATCH] Use EventLoopScheduler for rxops.timeout --- reactivex/operators/_timeout.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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]