Revert "fix: use methodQueue from rn to specify the dispatch queue"

This reverts commit b1ead45.

Author: santhoshvai

packages/react-native-sdk/ios/StreamInCallManager.swift

@@ -19,6 +19,8 @@ enum DefaultAudioDevice {
 @objc(StreamInCallManager)
 class StreamInCallManager: RCTEventEmitter {
 
+    private let audioSessionQueue = DispatchQueue(label: "io.getstream.rn.audioSessionQueue")
+    
     private var audioManagerActivated = false
     private var callAudioRole: CallAudioRole = .communicator
     private var defaultAudioDevice: DefaultAudioDevice = .speaker
@@ -44,55 +46,60 @@ class StreamInCallManager: RCTEventEmitter {
 
     @objc(setAudioRole:)
     func setAudioRole(audioRole: String) {
-        if audioManagerActivated {
-            log("AudioManager is already activated, audio role cannot be changed.")
-            return
+        audioSessionQueue.async { [self] in
+            if audioManagerActivated {
+                log("AudioManager is already activated, audio role cannot be changed.")
+                return
+            }
+            self.callAudioRole = audioRole.lowercased() == "listener" ? .listener : .communicator
         }
-        self.callAudioRole = audioRole.lowercased() == "listener" ? .listener : .communicator
-        
     }
 
     @objc(setDefaultAudioDeviceEndpointType:)
     func setDefaultAudioDeviceEndpointType(endpointType: String) {
-        if audioManagerActivated {
-            log("AudioManager is already activated, default audio device cannot be changed.")
-            return
+        audioSessionQueue.async { [self] in
+            if audioManagerActivated {
+                log("AudioManager is already activated, default audio device cannot be changed.")
+                return
+            }
+            self.defaultAudioDevice = endpointType.lowercased() == "earpiece" ? .earpiece : .speaker
         }
-        self.defaultAudioDevice = endpointType.lowercased() == "earpiece" ? .earpiece : .speaker
-        
     }
 
     @objc
     func start() {
-        if audioManagerActivated {
-            return
+        audioSessionQueue.async { [self] in
+            if audioManagerActivated {
+                return
+            }
+            let session = AVAudioSession.sharedInstance()
+            previousAudioSessionState = AudioSessionState(
+                category: session.category,
+                mode: session.mode,
+                options: session.categoryOptions
+            )
+            configureAudioSession()
+            audioManagerActivated = true
         }
-        let session = AVAudioSession.sharedInstance()
-        previousAudioSessionState = AudioSessionState(
-            category: session.category,
-            mode: session.mode,
-            options: session.categoryOptions
-        )
-        configureAudioSession()
-        audioManagerActivated = true
     }
 
     @objc
     func stop() {
-        if !audioManagerActivated {
-            return
-        }
-        if let prev = previousAudioSessionState {
-            let session = AVAudioSession.sharedInstance()
-            do {
-                try session.setCategory(prev.category, mode: prev.mode, options: prev.options)
-            } catch {
-                log("Error restoring previous audio session: \(error.localizedDescription)")
+        audioSessionQueue.async { [self] in
+            if !audioManagerActivated {
+                return
+            }
+            if let prev = previousAudioSessionState {
+                let session = AVAudioSession.sharedInstance()
+                do {
+                    try session.setCategory(prev.category, mode: prev.mode, options: prev.options)
+                } catch {
+                    log("Error restoring previous audio session: \(error.localizedDescription)")
+                }
+                previousAudioSessionState = nil
             }
-            previousAudioSessionState = nil
+            audioManagerActivated = false
         }
-        audioManagerActivated = false
-        
     }
 
     private func configureAudioSession() {
@@ -135,9 +142,6 @@ class StreamInCallManager: RCTEventEmitter {
 
         if currentCategory != intendedCategory.rawValue || currentMode != intendedMode.rawValue || currentOptions != intendedOptions || !currentIsActive {
             session.lockForConfiguration()
-            defer {
-                session.unlockForConfiguration()
-            }
             do {
                 try session.setCategory(intendedCategory, mode: intendedMode, options: intendedOptions)
                 try session.setActive(true)
@@ -152,6 +156,7 @@ class StreamInCallManager: RCTEventEmitter {
                     log("configureAudioSession: Error setting mode: \(error.localizedDescription)")
                 }
             }
+            session.unlockForConfiguration()
         } else {
             log("configureAudioSession: no change needed")
         }
@@ -290,11 +295,6 @@ class StreamInCallManager: RCTEventEmitter {
         }
     }
 
-    @objc
-    func methodQueue() -> DispatchQueue {
-        return DispatchQueue(label: "io.getstream.rn.audioSessionQueue")
-    }
-    
     // MARK: - Logging Helper
     private func log(_ message: String) {
         NSLog("InCallManager: %@", message)