Use concurrency and timers from StreamCore

Author: laevandus

Package.swift

@@ -29,7 +29,7 @@ let package = Package(
     ],
     dependencies: [
         .package(url: "https://github.com/apple/swift-docc-plugin", exact: "1.0.0"),
-        .package(url: "https://github.com/GetStream/stream-core-swift.git", exact: "0.4.1")
+        .package(url: "https://github.com/GetStream/stream-core-swift.git", branch: "chat-concurrency-and-timers")
     ],
     targets: [
         .target(

Sources/StreamChat/ChatClient+Environment.swift

@@ -78,7 +78,7 @@ extension ChatClient {
             _ syncRepository: SyncRepository,
             _ webSocketClient: WebSocketClient?,
             _ apiClient: APIClient,
-            _ timerType: Timer.Type
+            _ timerType: TimerScheduling.Type
         ) -> ConnectionRepository = {
             ConnectionRepository(
                 isClientInActiveMode: $0,
@@ -103,7 +103,7 @@ extension ChatClient {
             }
         }
 
-        var timerType: Timer.Type = DefaultTimer.self
+        var timerType: TimerScheduling.Type = DefaultTimer.self
 
         var tokenExpirationRetryStrategy: RetryStrategy = DefaultRetryStrategy()
 
@@ -132,7 +132,7 @@ extension ChatClient {
             _ databaseContainer: DatabaseContainer,
             _ connectionRepository: ConnectionRepository,
             _ tokenExpirationRetryStrategy: RetryStrategy,
-            _ timerType: Timer.Type
+            _ timerType: TimerScheduling.Type
         ) -> AuthenticationRepository = {
             AuthenticationRepository(
                 apiClient: $0,

Sources/StreamChat/Repositories/AuthenticationRepository.swift

@@ -97,14 +97,14 @@ class AuthenticationRepository: @unchecked Sendable {
     private let apiClient: APIClient
     private let databaseContainer: DatabaseContainer
     private let connectionRepository: ConnectionRepository
-    private let timerType: Timer.Type
+    private let timerType: TimerScheduling.Type
 
     init(
         apiClient: APIClient,
         databaseContainer: DatabaseContainer,
         connectionRepository: ConnectionRepository,
         tokenExpirationRetryStrategy: RetryStrategy,
-        timerType: Timer.Type
+        timerType: TimerScheduling.Type
     ) {
         self.apiClient = apiClient
         self.databaseContainer = databaseContainer

Sources/StreamChat/Repositories/ConnectionRepository.swift

@@ -26,14 +26,14 @@ class ConnectionRepository: @unchecked Sendable {
     private let syncRepository: SyncRepository
     private let webSocketClient: WebSocketClient?
     private let apiClient: APIClient
-    private let timerType: Timer.Type
+    private let timerType: TimerScheduling.Type
 
     init(
         isClientInActiveMode: Bool,
         syncRepository: SyncRepository,
         webSocketClient: WebSocketClient?,
         apiClient: APIClient,
-        timerType: Timer.Type
+        timerType: TimerScheduling.Type
     ) {
         self.isClientInActiveMode = isClientInActiveMode
         self.syncRepository = syncRepository

Sources/StreamChat/Utils/AllocatedUnfairLock.swift

@@ -13,7 +13,7 @@ protocol EventBatcher: Sendable {
     var currentBatch: Batch { get }
 
     /// Creates new batch processor.
-    init(period: TimeInterval, timerType: Timer.Type, handler: @escaping BatchHandler)
+    init(period: TimeInterval, timerType: TimerScheduling.Type, handler: @escaping BatchHandler)
 
     /// Adds the item to the current batch of events. If it's the first event also schedules batch processing
     /// that will happen when `period` has passed.
@@ -32,7 +32,7 @@ final class Batcher<Item> {
     /// The batching period. If the item is added sonner then `period` has passed after the first item they will get into the same batch.
     private let period: TimeInterval
     /// The time used to create timers.
-    private let timerType: Timer.Type
+    private let timerType: TimerScheduling.Type
     /// The timer that  calls `processor` when fired.
     private nonisolated(unsafe) var batchProcessingTimer: TimerControl?
     /// The closure which processes the batch.
@@ -44,7 +44,7 @@ final class Batcher<Item> {
 
     init(
         period: TimeInterval,
-        timerType: Timer.Type = DefaultTimer.self,
+        timerType: TimerScheduling.Type = DefaultTimer.self,
         handler: @escaping (_ batch: [Item], _ completion: @escaping @Sendable () -> Void) -> Void
     ) {
         self.period = max(period, 0)

Sources/StreamChat/Utils/Atomic.swift

@@ -15,7 +15,7 @@ class TypingStartCleanupMiddleware: EventMiddleware {
     /// after `start typing` event.
     let emitEvent: (Event) -> Void
     /// A timer type.
-    var timer: Timer.Type = DefaultTimer.self
+    var timer: TimerScheduling.Type = DefaultTimer.self
 
     /// A list of timers per user id.
     @Atomic private var typingEventTimeoutTimerControls: [UserId: TimerControl] = [:]
@@ -34,7 +34,7 @@ class TypingStartCleanupMiddleware: EventMiddleware {
             return event
         }
 
-        _typingEventTimeoutTimerControls {
+        _typingEventTimeoutTimerControls.mutate {
             $0[typingEvent.user.id]?.cancel()
             $0[typingEvent.user.id] = nil