From 90dc3329d1973fda691e357cf4523d5c7c67fa1d Mon Sep 17 00:00:00 2001
From: 杨锴 <841720330@qq.com>
Date: 星期二, 11 三月 2025 12:23:53 +0800
Subject: [PATCH] fix bug
---
Pods/RxSwift/RxSwift/Schedulers/VirtualTimeScheduler.swift | 24 ++++++++++++++----------
1 files changed, 14 insertions(+), 10 deletions(-)
diff --git a/Pods/RxSwift/RxSwift/Schedulers/VirtualTimeScheduler.swift b/Pods/RxSwift/RxSwift/Schedulers/VirtualTimeScheduler.swift
index 4f55d29..5d2d61e 100644
--- a/Pods/RxSwift/RxSwift/Schedulers/VirtualTimeScheduler.swift
+++ b/Pods/RxSwift/RxSwift/Schedulers/VirtualTimeScheduler.swift
@@ -24,6 +24,8 @@
private var nextId = 0
+ private let thread: Thread
+
/// - returns: Current time.
public var now: RxTime {
self.converter.convertFromVirtualTime(self.clock)
@@ -41,6 +43,7 @@
self.currentClock = initialClock
self.running = false
self.converter = converter
+ self.thread = Thread.current
self.schedulerQueue = PriorityQueue(hasHigherPriority: {
switch converter.compareVirtualTime($0.time, $1.time) {
case .lessThan:
@@ -106,8 +109,7 @@
- returns: The disposable object used to cancel the scheduled action (best effort).
*/
public func scheduleAbsoluteVirtual<StateType>(_ state: StateType, time: VirtualTime, action: @escaping (StateType) -> Disposable) -> Disposable {
- MainScheduler.ensureExecutingOnScheduler()
-
+ ensusreRunningOnCorrectThread()
let compositeDisposable = CompositeDisposable()
let item = VirtualSchedulerItem(action: {
@@ -130,12 +132,11 @@
/// Starts the virtual time scheduler.
public func start() {
- MainScheduler.ensureExecutingOnScheduler()
-
if self.running {
return
}
+ ensusreRunningOnCorrectThread()
self.running = true
repeat {
guard let next = self.findNext() else {
@@ -170,12 +171,11 @@
///
/// - parameter virtualTime: Absolute time to advance the scheduler's clock to.
public func advanceTo(_ virtualTime: VirtualTime) {
- MainScheduler.ensureExecutingOnScheduler()
-
if self.running {
fatalError("Scheduler is already running")
}
+ ensusreRunningOnCorrectThread()
self.running = true
repeat {
guard let next = self.findNext() else {
@@ -199,8 +199,7 @@
/// Advances the scheduler's clock by the specified relative time.
public func sleep(_ virtualInterval: VirtualTimeInterval) {
- MainScheduler.ensureExecutingOnScheduler()
-
+ ensusreRunningOnCorrectThread()
let sleepTo = self.converter.offsetVirtualTime(self.clock, offset: virtualInterval)
if self.converter.compareVirtualTime(sleepTo, self.clock).lessThen {
fatalError("Can't sleep to past.")
@@ -211,8 +210,7 @@
/// Stops the virtual time scheduler.
public func stop() {
- MainScheduler.ensureExecutingOnScheduler()
-
+ ensusreRunningOnCorrectThread()
self.running = false
}
@@ -221,6 +219,12 @@
_ = Resources.decrementTotal()
}
#endif
+
+ private func ensusreRunningOnCorrectThread() {
+ guard Thread.current == thread else {
+ rxFatalError("Executing on the wrong thread. Please ensure all work on the same thread.")
+ }
+ }
}
// MARK: description
--
Gitblit v1.7.1