fix ChannelState.addMessage

This commit is contained in:
Salvatore Giordano
2021-03-01 10:12:41 +01:00
parent 3c595d98f7
commit 578c4efade
2 changed files with 2 additions and 1 deletions
@@ -1441,7 +1441,7 @@ class ChannelClientState {
final oldIndex = newMessages.indexWhere((m) => m.id == message.id);
if (oldIndex != -1) {
newMessages[oldIndex] = newMessages[oldIndex].merge(message);
newMessages[oldIndex] = message;
} else {
newMessages.add(message);
}
@@ -47,6 +47,7 @@ class RetryQueue {
/// Add a list of messages
void add(List<Message> messages) {
logger?.info('added ${messages.length} messages');
final messageList = _messageQueue.toList();
_messageQueue.addAll(messages
.where((element) => !messageList.any((m) => m.id == element.id)));