implement a way to automatically reconnect and resubscribe if the Redis server is restarted

[insinfo]

implement a way to automatically reconnect or resubscribe if the Redis server is restarted

void main() async {
    await initRedisSubscribe();
}
...
Future<void> initRedisSubscribe() async {
    var redisCommand = await getCurrentRedisConnection();

        redisPubSub = PubSub(redisCommand);
   
    redisPubSub.subscribe(['notification']);
    final stream = redisPubSub.getStream();

    var streamWithoutErrors = stream
        .handleError((e) => print('NotificationService redisPubSub error $e'));

    streamWithoutErrors.listen((msg) {
      var kind = msg[0];
      var data = msg[2];
      if (kind == 'message') {
        var map = jsonDecode(data);
        var notification = Notification.fromMap(map);
        sendNotifications(notification);
      }
      // else {
      //  print('received non-message ${msg}');
      //}
    });
  }

[ra1u]

What I would do here is to convert into async for loop as https://dart.dev/tutorials/language/streams#receiving-stream-events
When for loop terminates, you can retry everything again, including . getCurrentRedisConnection

Here is code, that is probably wrong, as I did not run trough compiler.

Future<void> initRedisSubscribe() async {
  while(true){
    var redisCommand = await getCurrentRedisConnection();
    redisPubSub = PubSub(redisCommand);
   
    redisPubSub.subscribe(['notification']);
    final stream = redisPubSub.getStream();

    var streamWithoutErrors = stream
        .handleError((e) => print('NotificationService redisPubSub error $e'));

    await for (final msg in streamWithoutErrors) {
      var kind = msg[0];
      var data = msg[2];
      if (kind == 'message') {
        var map = jsonDecode(data);
        var notification = Notification.fromMap(map);
        sendNotifications(notification);
      }
      // else {
      //  print('received non-message ${msg}');
      //}
    }
    // stream is done, back to while
  }
}