MQTT updates not working while changing Networks about mqtt_client HOT 9 CLOSED

connectMQTT(){
try {
  debugPrint('NEW 🦟 MQTT2 🦟 CONNECT FROM $from');
  await newMQTTclient!.connect();

  if (newMQTTclient!.connectionStatus!.state ==
      MqttConnectionState.connected) {
    debugPrint('NEW 🦟 MQTT2 🦟 CONNECTED');
  } else {
    /// Use status here rather than state if you also want the broker return code.
    debugPrint(
        'NEW 🦟 MQTT2 🦟 DISCONNECTING ${newMQTTclient!.connectionStatus}');
    newMQTTclient!.disconnect();
    exit(-1);
  }

  debugPrint('NEW 🦟 MQTT2-CHECK:: ${newMQTTclient == null}');
  debugPrint(
      'NEW 🦟 MQTT2-UPDATE CHECK:: ${newMQTTclient!.updates == null}');

  newMQTTclient!.published!.listen((MqttPublishMessage message) {
    var payload =
        MqttPublishPayload.bytesToStringAsString(message.payload.message);
    debugPrint('NEW 🦟 MQTT2 PUBLISHED:: ${payload}');
  });

  newMQTTclient!.updates!.listen(
    (List<MqttReceivedMessage<MqttMessage?>>? c) {
      debugPrint('NEW 🦟 MQTT2 ON UPDATES - {$c}');
      for (int i = 0; i < c!.length; i++) {
        final MqttPublishMessage message =
            c[i].payload as MqttPublishMessage;
        var payload = MqttPublishPayload.bytesToStringAsString(
            message.payload.message);
        debugPrint(
            "NEW 🦟 MQTT2 🦟 RESPONSE NEW  ${DateTime.now()} $payload");
        DeviceResponseUtils()
            .handleResponse(str: payload, ipAddress: "", isMqtt: true);
      }
    },
    cancelOnError: true,
    onError: (Object error) {
      debugPrint('NEW 🦟 MQTT2 ON ERROR - UPDATES');
    },
    onDone: () {
      debugPrint('NEW 🦟 MQTT2 ON DONE - UPDATES');
    },
  );

} on NoConnectionException catch (e) {
  debugPrint('${DateTime.now()} NEW 🦟 MQTT2 🦟 :client exception - $e');
  newMQTTclient!.disconnect();
} on SocketException catch (e) {
  debugPrint('${DateTime.now()} NEW 🦟 MQTT2 🦟 :socket exception - $e');
  newMQTTclient!.disconnect();
}

subscribeDevices();
}

 void subscribeDevices({String? from}) {
    await Device().fetchAllNewDevices().then((listDevice) {
      for (var device in listDevice) {
        subscribeTopics(device, from: from);
      }
    });
  }

Future<void> subscribeTopics(DeviceResponse? deviceResponse,
    {String? from}) async {
  if (newMQTTclient != null &&
      newMQTTclient!.connectionStatus!.state ==
          MqttConnectionState.connected) {
    String topicToSubscribe =
        generateSlaveFromDeviceId(deviceId: deviceResponse!.deviceId!) +
            newMqttSubscribeTopic;
    debugPrint("NEW 🦟 MQTT2 🦟 TOPIC TO SUBSCRIBE --> $topicToSubscribe");

    debugPrint(
        "NEW 🦟 MQTT2 🦟 SUBSCRIPTIONS --> ${newMQTTclient!.subscriptionsManager!.subscriptions}");

    if (newMQTTclient!.subscriptionsManager != null &&
        newMQTTclient!.subscriptionsManager!.subscriptions
            .containsKey(topicToSubscribe)) {
      debugPrint(
          "NEW 🦟 MQTT2 🦟 SUBSCRIBE ALREADY ACTIVE--> $topicToSubscribe");
      sendDS(deviceResponse);
    } else {
      debugPrint(
          "NEW 🦟 MQTT2 🦟 CURRENT SUBSCRIPTIONS--> ${newMQTTclient!.subscriptionsManager!.subscriptions}}");

      newMQTTclient!.subscribe(topicToSubscribe, MqttQos.atMostOnce);
    }
  }
}

.....
mqttClient!.autoReconnect = true;
mqttClient!.onAutoReconnected = onAutoReconnected;
await mqttClient!.connect();
.....

 /// Client disconnect callback, called on unsolicited disconnect.
  /// This will not be called even if set if [autoReconnect} is set,instead
  /// [AutoReconnectCallback] will be called.

/// Client disconnect callback, called on unsolicited disconnect.
  /// This will not be called even if set if [autoReconnect} is set,instead
  /// [AutoReconnectCallback] will be called.
  DisconnectCallback? onDisconnected;

  /// Client connect callback, called on successful connect
  ConnectCallback? onConnected;

  /// Auto reconnect callback, if auto reconnect is selected this callback will
  /// be called before auto reconnect processing is invoked to allow the user to
  /// perform any pre auto reconnect actions.
  AutoReconnectCallback? onAutoReconnect;

  /// Auto reconnected callback, if auto reconnect is selected this callback will
  /// be called after auto reconnect processing is completed to allow the user to
  /// perform any post auto reconnect actions.
  AutoReconnectCompleteCallback? onAutoReconnected;