checkpoint on persistent queue update

This commit is contained in:
Christien Rioux 2025-05-30 22:06:20 -04:00
parent 6421a77572
commit b7752a7e95
5 changed files with 80 additions and 36 deletions

View file

@ -107,6 +107,7 @@ class SingleContactMessagesCubit extends Cubit<SingleContactMessagesState> {
table: 'SingleContactUnsentMessages',
key: _remoteConversationRecordKey.toString(),
fromBuffer: proto.Message.fromBuffer,
toBuffer: (x) => x.writeToBuffer(),
closure: _processUnsentMessages,
onError: (e, st) {
log.error('Exception while processing unsent messages: $e\n$st\n');