retryFailedMessages method
Retry failed message.
Implementation
Future<void> retryFailedMessages() async {
final failedMessages = [...messages, ...threads.values.expand((v) => v)]
.where((it) => it.state.isFailed);
_retryQueue.add(failedMessages);
}