Fix Throttler crash in ChatChannelViewModel.handleMessageAppear() (#1050)

Author: nuno-vieira

CHANGELOG.md

@@ -8,6 +8,10 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 - Expose `FilePickerView.init(fileURLs:)` [#1049](https://github.com/GetStream/stream-chat-swiftui/pull/1049)
 - Add `MessageComposerViewModel.updateAddedAssets()` [#1049](https://github.com/GetStream/stream-chat-swiftui/pull/1049)
 
+### 🐞 Fixed
+- Fix `Throttler` crash in `ChatChannelViewModel.handleMessageAppear()` [#1050](https://github.com/GetStream/stream-chat-swiftui/pull/1050)
+- Remove unnecessary channel query call when leaving the channel view in a mid-page [#1050](https://github.com/GetStream/stream-chat-swiftui/pull/1050)
+
 # [4.92.0](https://github.com/GetStream/stream-chat-swiftui/releases/tag/4.92.0)
 _November 07, 2025_
 

Sources/StreamChatSwiftUI/ChatChannel/ChatChannelViewModel.swift

@@ -50,7 +50,7 @@ open class ChatChannelViewModel: ObservableObject, MessagesDataSource {
     private var channelName = ""
     private var onlineIndicatorShown = false
     private var lastReadMessageId: String?
-    var throttler = Throttler(interval: 3, broadcastLatestEvent: true)
+    var throttler = Throttler(interval: 3, broadcastLatestEvent: true, queue: .main)
 
     public var channelController: ChatChannelController
     public var messageController: ChatMessageController?
@@ -833,14 +833,12 @@ open class ChatChannelViewModel: ObservableObject, MessagesDataSource {
     }
 
     deinit {
+        throttler.cancel()
         messageCachingUtils.clearCache()
         if messageController == nil {
             utils.channelControllerFactory.clearCurrentController()
             cleanupAudioPlayer()
             ImageCache.shared.trim(toCost: utils.messageListConfig.cacheSizeOnChatDismiss)
-            if !channelDataSource.hasLoadedAllNextMessages {
-                channelDataSource.loadFirstPage { _ in }
-            }
         }
     }
 }

StreamChatSwiftUITests/Tests/ChatChannel/ChatChannelViewModel_Tests.swift

@@ -772,6 +772,31 @@ class ChatChannelViewModel_Tests: StreamChatTestCase {
         XCTAssertEqual(0, channelController.markReadCallCount)
     }
 
+    func test_chatChannelVM_handleMessageAppear_doesNotCrashWhenDeallocated() {
+        let message = ChatMessage.mock()
+        let channelController = makeChannelController(messages: [message])
+        channelController.hasLoadedAllNextMessages_mock = nil
+        channelController.channel_mock = .mock(
+            cid: .unique,
+            unreadCount: ChannelUnreadCount(messages: 1, mentions: 0)
+        )
+
+        for _ in 0..<1000 {
+            autoreleasepool {
+                let viewModel = ChatChannelViewModel(channelController: channelController)
+                viewModel.handleMessageAppear(index: 0, scrollDirection: .down)
+                viewModel.handleMessageAppear(index: 0, scrollDirection: .down)
+                viewModel.handleMessageAppear(index: 0, scrollDirection: .down)
+                viewModel.handleMessageAppear(index: 0, scrollDirection: .down)
+                viewModel.handleMessageAppear(index: 0, scrollDirection: .down)
+                viewModel.handleMessageAppear(index: 0, scrollDirection: .down)
+            }
+        }
+        
+        // Then - Should not crash
+        XCTAssert(true)
+    }
+
     // MARK: - highlightMessage Tests
 
     func test_highlightMessage_highlightsWhenSkipHighlightMessageIdIsNotSet() {