retryFailedMessages method

Future<void> retryFailedMessages()

Retry failed message.

Implementation

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