retryFailedMessages method

Future<void> retryFailedMessages()

Retry failed message.

Implementation

Future<void> retryFailedMessages() async {
  final failedMessages = [...messages, ...threads.values.expand((v) => v)]
      .where(
        (message) =>
            message.status != MessageSendingStatus.sent &&
            message.createdAt.isBefore(
              DateTime.now().subtract(const Duration(seconds: 5)),
            ),
      )
      .toList();

  _retryQueue.add(failedMessages);
}