Fix TritonKit observer concurrency

Author: linhay

Sources/TritonKit/TritonKit.swift

@@ -179,6 +179,7 @@ public class TritonKit {
     public weak var delegate: TritonKitDelegate?
     public private(set) var state: ConnectionState = .disconnected {
         didSet {
+            guard oldValue != state else { return }
             delegate?.tritonKit(self, didChangeState: state)
             notifyStateObservers(state)
         }
@@ -193,6 +194,7 @@ public class TritonKit {
     private var pingTimer: Timer?
     private var defaultRequestHandler: TritonKitRequestHandler?
     private var isStarted = false
+    private let observerLock = NSLock()
     private var stateObservers: [UUID: (ConnectionState) -> Void] = [:]
     private var errorObservers: [UUID: (Error) -> Void] = [:]
     internal var endpointReadinessTimeout: TimeInterval = 0.25
@@ -256,19 +258,30 @@ public class TritonKit {
     @discardableResult
     public func onStateChange(_ handler: @escaping (ConnectionState) -> Void) -> ObservationToken {
         let id = UUID()
+        observerLock.lock()
         stateObservers[id] = handler
-        handler(state)
+        let currentState = state
+        observerLock.unlock()
+        handler(currentState)
         return ObservationToken { [weak self] in
-            self?.stateObservers.removeValue(forKey: id)
+            guard let self else { return }
+            self.observerLock.lock()
+            self.stateObservers.removeValue(forKey: id)
+            self.observerLock.unlock()
         }
     }
 
     @discardableResult
     public func onError(_ handler: @escaping (Error) -> Void) -> ObservationToken {
         let id = UUID()
+        observerLock.lock()
         errorObservers[id] = handler
+        observerLock.unlock()
         return ObservationToken { [weak self] in
-            self?.errorObservers.removeValue(forKey: id)
+            guard let self else { return }
+            self.observerLock.lock()
+            self.errorObservers.removeValue(forKey: id)
+            self.observerLock.unlock()
         }
     }
 
@@ -441,14 +454,20 @@ public class TritonKit {
     }
 
     private func notifyStateObservers(_ state: ConnectionState) {
-        for observer in Array(stateObservers.values) {
+        observerLock.lock()
+        let observers = Array(stateObservers.values)
+        observerLock.unlock()
+        for observer in observers {
             observer(state)
         }
     }
 
     private func notifyError(_ error: Error) {
         delegate?.tritonKit(self, didReceiveError: error)
-        for observer in Array(errorObservers.values) {
+        observerLock.lock()
+        let observers = Array(errorObservers.values)
+        observerLock.unlock()
+        for observer in observers {
             observer(error)
         }
     }

Tests/TritonKitTests/TKPlatformFallbackTests.swift

@@ -103,6 +103,8 @@ struct TKPlatformFallbackTests {
             observed.append(state)
         }
 
+        #expect(observed == [TritonKit.shared.state])
+        TritonKit.shared.stop()
         #expect(observed == [TritonKit.shared.state])
         token.cancel()
     }

docs-linhay/memory/2026-06-07.md

@@ -49,3 +49,14 @@
   - `swift test --filter TKHostAdapterModelsTests` 通过。
   - `swift test --package-path CLI --scratch-path .build/cli --filter DeviceCrossPlatformTests` 通过。
   - `docs-linhay/scripts/verify.sh --local` 通过。
+
+## 主仓合并后门禁修复
+
+- Android feature fast-forward 合入主仓后，主仓 `docs-linhay/scripts/verify.sh --local` 暴露 `TKPlatformFallbackTests` 在 Swift Testing 并发执行下会偶发重复收到 `.disconnected` 状态，并在 suite 级重跑时触发 `stateObservers` 字典并发读写崩溃。
+- 修复：
+  - `TritonKit.state` 只有状态真实变化时才通知 delegate / state observers。
+  - `stateObservers` 与 `errorObservers` 增加锁保护，注册、取消和通知时先拷贝 observer 列表再回调。
+  - `stateObserverToken` 测试增加重复 `stop()` 不应重复广播当前状态的断言。
+- 回归：
+  - `swift test --filter TKPlatformFallbackTests` 通过。
+  - 主仓 `docs-linhay/scripts/verify.sh --local` 通过。