retryFailedMessages method

Future<void> retryFailedMessages()

Retry failed message.

Implementation

Future<void> retryFailedMessages() async {
  final failedMessages =
      <Message>[...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);
}