From 3f38a96d4fcf25f1427dd235f3a1194df1c3ca29 Mon Sep 17 00:00:00 2001 From: cloudwebrtc Date: Mon, 8 Aug 2022 22:54:08 +0800 Subject: [PATCH] chore: Remove the previous room state listener method. --- lib/src/voip/group_call.dart | 29 ----------------------------- 1 file changed, 29 deletions(-) diff --git a/lib/src/voip/group_call.dart b/lib/src/voip/group_call.dart index 94c88925..e6667d06 100644 --- a/lib/src/voip/group_call.dart +++ b/lib/src/voip/group_call.dart @@ -197,9 +197,6 @@ class GroupCall { Timer? activeSpeakerLoopTimeout; - Timer? retryCallLoopTimeout; - Map retryCallCounts = {}; - final CachedStreamController onGroupCallFeedsChanged = CachedStreamController(); @@ -430,8 +427,6 @@ class GroupCall { onMemberStateChanged(stateEvent); }); - retryCallLoopTimeout = Timer.periodic( - Duration(milliseconds: retryCallInterval), onRetryCallLoop); onActiveSpeakerLoop(); voip.currentGroupCID = groupCallId; @@ -467,8 +462,6 @@ class GroupCall { activeSpeaker = null; activeSpeakerLoopTimeout?.cancel(); - retryCallCounts.clear(); - retryCallLoopTimeout?.cancel(); _callSubscription?.cancel(); } @@ -876,24 +869,6 @@ class GroupCall { return memberDevices[0]; } - /// Monitor member status and respond to mesh calls by regularly updating - /// the state event in the room - void onRetryCallLoop(Timer _) async { - final memberStateEvents = - await getStateEventsList(EventTypes.GroupCallMemberPrefix); - - memberStateEvents.forEach((event) { - final memberId = event.senderId; - final existingCall = - calls.indexWhere((call) => call.remoteUser!.id == memberId) != -1; - final retryCallCount = retryCallCounts[memberId] ?? 0; - if (!existingCall && retryCallCount < 3) { - retryCallCounts[memberId] = retryCallCount + 1; - onMemberStateChanged(event); - } - }); - } - CallSession? getCallByUserId(String userId) { final value = calls.where((item) => item.remoteUser!.id == userId); if (value.isNotEmpty) { @@ -1064,10 +1039,6 @@ class GroupCall { call.isLocalVideoMuted != videoMuted) { call.setLocalVideoMuted(videoMuted); } - - if (state == CallState.kConnected) { - retryCallCounts.remove(call.remoteUser!.id); - } } void onCallHangup(CallSession call) {