[Fix]MicrophoneChecker occasional crash (#813)

Author: ipavlidakis

CHANGELOG.md

@@ -10,6 +10,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
 ### 🐞 Fixed
 - Fix a retain cycle that was causing StreamVideo to leak in projects using NoiseCancellation. [#814](https://github.com/GetStream/stream-video-swift/pull/814)
+- Fix occasional crash caused inside `MicrophoneChecker`. [#813](https://github.com/GetStream/stream-video-swift/pull/813)
 
 # [1.22.2](https://github.com/GetStream/stream-video-swift/releases/tag/1.22.2)
 _May 13, 2025_

Sources/StreamVideo/WebRTC/v2/Extensions/Foundation/Publisher+TaskSink.swift

@@ -87,12 +87,13 @@ extension Publisher where Output: Sendable {
                 // Skip processing if the queue is unavailable.
                 return
             }
+            let capturedInput = input
             // Schedule the task on the provided serial actor queue.
             queue.async {
                 do {
                     // Check for task cancellation and process the value.
                     try Task.checkCancellation()
-                    try await receiveValue(input)
+                    try await receiveValue(capturedInput)
                 } catch let error as Failure {
                     // Handle specific failure cases.
                     receiveCompletion(.failure(error))

Sources/StreamVideoSwiftUI/CallingViews/MicrophoneChecker.swift

@@ -56,9 +56,9 @@ public final class MicrophoneChecker: ObservableObject {
                 if updateMetersCancellable == nil {
                     updateMetersCancellable = audioRecorder
                         .metersPublisher
-                        .sinkTask(queue: serialQueue) { @MainActor [weak self] in
-                            self?.didReceiveUpdatedMeters($0)
-                        }
+                        .compactMap { [weak self] in self?.normaliseAndAppend($0) }
+                        .receive(on: DispatchQueue.main)
+                        .assign(to: \.audioLevels, onWeak: self)
                 }
             }
         } catch {
@@ -91,14 +91,14 @@ public final class MicrophoneChecker: ObservableObject {
 
     // MARK: - private
 
-    private func didReceiveUpdatedMeters(_ decibel: Float) {
+    private func normaliseAndAppend(_ decibel: Float) -> [Float] {
         let normalisedAudioLevel = audioNormaliser.normalise(decibel)
         var temp = audioLevels
         temp.append(normalisedAudioLevel)
         if temp.count > valueLimit {
             temp = Array(temp.dropFirst())
         }
-        audioLevels = temp
+        return temp
     }
 }
 

StreamVideoSwiftUITests/CallingViews/MicrophoneChecker_Tests.swift

@@ -11,6 +11,7 @@ import XCTest
 
 final class MicrophoneChecker_Tests: XCTestCase, @unchecked Sendable {
 
+    private nonisolated(unsafe) static var originalCallAudioRecorder: StreamCallAudioRecorder! = StreamCallAudioRecorderKey.currentValue
     private lazy var mockStreamVideo: MockStreamVideo! = .init()
     private lazy var subject: MicrophoneChecker! = .init(valueLimit: 3)
     private lazy var mockAudioRecorder: MockStreamCallAudioRecorder! = MockStreamCallAudioRecorder(filename: "test.wav")
@@ -23,13 +24,18 @@ final class MicrophoneChecker_Tests: XCTestCase, @unchecked Sendable {
 
     override func tearDown() async throws {
         await subject.stopListening()
-        InjectedValues[\.callAudioRecorder] = StreamCallAudioRecorderKey.currentValue
+        InjectedValues[\.callAudioRecorder] = Self.originalCallAudioRecorder
         mockAudioRecorder = nil
         mockStreamVideo = nil
         subject = nil
         try await super.tearDown()
     }
 
+    override class func tearDown() {
+        Self.originalCallAudioRecorder = nil
+        super.tearDown()
+    }
+
     // MARK: - init
 
     func test_startListening_startListeningWasCalledOnAudioRecorder() async {
@@ -49,7 +55,6 @@ final class MicrophoneChecker_Tests: XCTestCase, @unchecked Sendable {
     // MARK: - audioLevels
 
     func test_startListeningAndPostAudioLevels_microphoneCheckerHasExpectedValues() async throws {
-        LogConfig.level = .debug
         await subject.startListening()
 
         let inputs = [
@@ -61,7 +66,7 @@ final class MicrophoneChecker_Tests: XCTestCase, @unchecked Sendable {
 
         for value in inputs {
             mockAudioRecorder.mockMetersPublisher.send(Float(value))
-            try? await Task.sleep(nanoseconds: 100_000)
+            await wait(for: 0.1)
         }
 
         let values = try await subject