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

Merge branch 'td/groupCallStateUpdates' into 'main' 

fix: update groupCalls state stream

See merge request famedly/company/frontend/famedlysdk!1217
This commit is contained in:
td 2023-01-23 06:48:06 +00:00
parent e81fce1f1f 5510049dec
commit 73af358764
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);
} }