sendMessagesToServerAgain method

Future<void> sendMessagesToServerAgain(
  1. int milliseconds
)

Implementation

Future<void> sendMessagesToServerAgain(int milliseconds) async {
  for (final pendingRequest in [..._pendingRequestsList]
      .where((element) => !element.serverReceived)
      .where((element) => element.createdAt.millisecondsSinceEpoch - 10 < DateTime.now().millisecondsSinceEpoch - milliseconds)
  ) {
    ws.sinkAdd(map: pendingRequest.data);
  }
}