Git-Mirrors/veilidchat
1
0
Fork 0
mirror of https://gitlab.com/veilid/veilidchat.git synced 2025-08-03 19:54:27 -04:00
Code Issues Projects Releases Packages Wiki Activity

bugfixes

Browse source 
flutter 3.19 upgrade
This commit is contained in:
Christien Rioux 2024-02-27 21:37:39 -05:00
parent c6f017b0d1
commit efb7b95980
17 changed files with 131 additions and 127 deletions
Download patch file Download diff file Expand all files Collapse all files

10
lib/contacts/cubits/conversation_cubit.dart
View file

@ -73,6 +73,8 @@ class ConversationCubit extends Cubit<AsyncValue<ConversationState>> {
@override
Future<void> close() async {
await _localSubscription?.cancel();
await _remoteSubscription?.cancel();
await super.close();
}
@ -127,7 +129,8 @@ class ConversationCubit extends Cubit<AsyncValue<ConversationState>> {
_localConversationCubit = DefaultDHTRecordCubit.value(
record: localConversationRecord,
decodeState: proto.Conversation.fromBuffer);
_localConversationCubit!.stream.listen(updateLocalConversationState);
_localSubscription =
_localConversationCubit!.stream.listen(updateLocalConversationState);
}
// Open remote converation key
@ -138,7 +141,8 @@ class ConversationCubit extends Cubit<AsyncValue<ConversationState>> {
_remoteConversationCubit = DefaultDHTRecordCubit.value(
record: remoteConversationRecord,
decodeState: proto.Conversation.fromBuffer);
_remoteConversationCubit!.stream.listen(updateRemoteConversationState);
_remoteSubscription =
_remoteConversationCubit!.stream.listen(updateRemoteConversationState);
}
// Initialize a local conversation
@ -265,6 +269,8 @@ class ConversationCubit extends Cubit<AsyncValue<ConversationState>> {
final TypedKey? _remoteConversationRecordKey;
DefaultDHTRecordCubit<proto.Conversation>? _localConversationCubit;
DefaultDHTRecordCubit<proto.Conversation>? _remoteConversationCubit;
StreamSubscription<AsyncValue<proto.Conversation>>? _localSubscription;
StreamSubscription<AsyncValue<proto.Conversation>>? _remoteSubscription;
ConversationState _incrementalState;
//
DHTRecordCrypto? _conversationCrypto;