From 785893b1ff55d6e2a58d6ce70149fcb83978851d Mon Sep 17 00:00:00 2001 From: Serhii Bykov Date: Sun, 20 Jul 2025 18:57:41 +0300 Subject: [PATCH] VirtualTimeScheduler - fix typo --- RxSwift/Schedulers/VirtualTimeScheduler.swift | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/RxSwift/Schedulers/VirtualTimeScheduler.swift b/RxSwift/Schedulers/VirtualTimeScheduler.swift index 5d2d61e14..0a801d9c9 100644 --- a/RxSwift/Schedulers/VirtualTimeScheduler.swift +++ b/RxSwift/Schedulers/VirtualTimeScheduler.swift @@ -109,7 +109,7 @@ open class VirtualTimeScheduler - returns: The disposable object used to cancel the scheduled action (best effort). */ public func scheduleAbsoluteVirtual(_ state: StateType, time: VirtualTime, action: @escaping (StateType) -> Disposable) -> Disposable { - ensusreRunningOnCorrectThread() + ensureRunningOnCorrectThread() let compositeDisposable = CompositeDisposable() let item = VirtualSchedulerItem(action: { @@ -136,7 +136,7 @@ open class VirtualTimeScheduler return } - ensusreRunningOnCorrectThread() + ensureRunningOnCorrectThread() self.running = true repeat { guard let next = self.findNext() else { @@ -175,7 +175,7 @@ open class VirtualTimeScheduler fatalError("Scheduler is already running") } - ensusreRunningOnCorrectThread() + ensureRunningOnCorrectThread() self.running = true repeat { guard let next = self.findNext() else { @@ -199,7 +199,7 @@ open class VirtualTimeScheduler /// Advances the scheduler's clock by the specified relative time. public func sleep(_ virtualInterval: VirtualTimeInterval) { - ensusreRunningOnCorrectThread() + ensureRunningOnCorrectThread() let sleepTo = self.converter.offsetVirtualTime(self.clock, offset: virtualInterval) if self.converter.compareVirtualTime(sleepTo, self.clock).lessThen { fatalError("Can't sleep to past.") @@ -210,7 +210,7 @@ open class VirtualTimeScheduler /// Stops the virtual time scheduler. public func stop() { - ensusreRunningOnCorrectThread() + ensureRunningOnCorrectThread() self.running = false } @@ -220,7 +220,7 @@ open class VirtualTimeScheduler } #endif - private func ensusreRunningOnCorrectThread() { + private func ensureRunningOnCorrectThread() { guard Thread.current == thread else { rxFatalError("Executing on the wrong thread. Please ensure all work on the same thread.") }