Merge pull request #57 from GetStream/fix/fix-concurency-issues

Fix concurency issuse on local tracks

Author: Brazol

CHANGELOG.md

@@ -1,6 +1,9 @@
 
 # Changelog
 
+[2.2.3] - 2025-12-22
+* [Android] Fixed concurrency issues in local tracks access that could cause a crash.
+
 [2.2.2] - 2025-12-19
 * [Android] Added support for screen sharing audio on Android by mixing the microphone audio with recorded screen audio.
 

android/src/main/java/io/getstream/webrtc/flutter/MethodCallHandlerImpl.java

@@ -111,13 +111,13 @@
 public class MethodCallHandlerImpl implements MethodCallHandler, StateProvider {
   static public final String TAG = "FlutterWebRTCPlugin";
 
-  private final Map<String, PeerConnectionObserver> mPeerConnectionObservers = new HashMap<>();
+  private final ConcurrentHashMap<String, PeerConnectionObserver> mPeerConnectionObservers = new ConcurrentHashMap<>();
   private final BinaryMessenger messenger;
   private final Context context;
   private final TextureRegistry textures;
   private PeerConnectionFactory mFactory;
-  private final Map<String, MediaStream> localStreams = new HashMap<>();
-  private final Map<String, LocalTrack> localTracks = new HashMap<>();
+  private final ConcurrentHashMap<String, MediaStream> localStreams = new ConcurrentHashMap<>();
+  private final ConcurrentHashMap<String, LocalTrack> localTracks = new ConcurrentHashMap<>();
   private final LongSparseArray<FlutterRTCVideoRenderer> renders = new LongSparseArray<>();
 
   public RecordSamplesReadyCallbackAdapter recordSamplesReadyCallbackAdapter;
@@ -149,8 +149,8 @@ public class MethodCallHandlerImpl implements MethodCallHandler, StateProvider {
   public AudioProcessingFactoryProvider audioProcessingFactoryProvider;
 
   private ConstraintsMap initializedAndroidAudioConfiguration;
-  private final Map<String, Double> trackVolumeCache = new ConcurrentHashMap<>();
-  private final Map<String, Double> pausedTrackVolumes = new ConcurrentHashMap<>();
+  private final ConcurrentHashMap<String, Double> trackVolumeCache = new ConcurrentHashMap<>();
+  private final ConcurrentHashMap<String, Double> pausedTrackVolumes = new ConcurrentHashMap<>();
   private volatile boolean isAudioPlayoutPaused = false;
 
   public static class LogSink implements Loggable {
@@ -209,16 +209,13 @@ void dispose() {
    * tracks.
    */
   private boolean isMicrophoneMuted() {
-    synchronized (localTracks) {
-      for (LocalTrack track : localTracks.values()) {
-        if (track instanceof LocalAudioTrack) {
-          if (track.enabled()) {
-            return false; 
-          }
+    for (LocalTrack track : localTracks.values()) {
+      if (track instanceof LocalAudioTrack) {
+        if (track.enabled()) {
+          return false; 
         }
       }
     }
-
     return true; 
   }
 

ios/stream_webrtc_flutter.podspec

@@ -3,7 +3,7 @@
 #
 Pod::Spec.new do |s|
   s.name             = 'stream_webrtc_flutter'
-  s.version          = '2.2.2'
+  s.version          = '2.2.3'
   s.summary          = 'Flutter WebRTC plugin for iOS.'
   s.description      = <<-DESC
 A new flutter plugin project.

lib/stream_webrtc_flutter.dart

@@ -25,4 +25,4 @@ export 'src/native/rtc_video_platform_view_controller.dart';
 export 'src/native/rtc_video_platform_view.dart';
 
 const String androidWebRTCVersion = '137.0.1';
-const String iosWebRTCVersion = '137.0.43';
+const String iosWebRTCVersion = '137.0.54';

macos/stream_webrtc_flutter.podspec

@@ -3,7 +3,7 @@
 #
 Pod::Spec.new do |s|
   s.name             = 'stream_webrtc_flutter'
-  s.version          = '2.2.2'
+  s.version          = '2.2.3'
   s.summary          = 'Flutter WebRTC plugin for macOS.'
   s.description      = <<-DESC
 A new flutter plugin project.

pubspec.yaml

@@ -1,6 +1,6 @@
 name: stream_webrtc_flutter
 description: Flutter WebRTC plugin for iOS/Android/Destkop/Web, based on GoogleWebRTC.
-version: 2.2.2
+version: 2.2.3
 homepage: https://github.com/GetStream/webrtc-flutter
 environment:
   sdk: ">=3.6.0 <4.0.0"