OfficialDakari
/
matrix-dart-sdk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: update groupCalls state stream 

refactor: add a try catch around disposing streams. Decoding streams is broken in flutter_webrtc atm
This commit is contained in:
td 2023-01-23 06:43:35 +05:30
parent e81fce1f1f
commit 5510049dec
No known key found for this signature in database
GPG Key ID: F6D9E9BF14C7D103
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
lib/src/voip/call.dart
View File

@ -1201,13 +1201,17 @@ class CallSession {
} }
Future<void> cleanUp() async { Future<void> cleanUp() async {
for (final stream in streams) { try {
await stream.dispose(); for (final stream in streams) {
} await stream.dispose();
streams.clear(); }
if (pc != null) { streams.clear();
await pc!.close(); if (pc != null) {
await pc!.dispose(); await pc!.close();
await pc!.dispose();
}
} catch (e) {
Logs().e('cleaning up streams failed', e);
} }
} }

3
lib/src/voip/group_call.dart
View File

@ -211,7 +211,7 @@ class GroupCall {
final CachedStreamController<GroupCall> onGroupCallFeedsChanged = final CachedStreamController<GroupCall> onGroupCallFeedsChanged =
CachedStreamController(); CachedStreamController();
final CachedStreamController<GroupCallState> onGroupCallState = final CachedStreamController<String> onGroupCallState =
CachedStreamController(); CachedStreamController();
final CachedStreamController<String> onGroupCallEvent = final CachedStreamController<String> onGroupCallEvent =
@ -294,6 +294,7 @@ class GroupCall {
void setState(String newState) { void setState(String newState) {
state = newState; state = newState;
onGroupCallState.add(newState);
onGroupCallEvent.add(GroupCallEvent.GroupCallStateChanged); onGroupCallEvent.add(GroupCallEvent.GroupCallStateChanged);
} }