connect method

  1. @override
Future<MqttClientConnectionStatus?> connect([
  1. String? username,
  2. String? password
])
override

Performs a connect to the message broker with an optional username and password for the purposes of authentication. If a username and password are supplied these will override any previously set in a supplied connection message so if you supply your own connection message and use the authenticateAs method to set these parameters do not set them again here.

Implementation

@override
Future<MqttClientConnectionStatus?> connect(
    [String? username, String? password]) async {
  instantiationCorrect = true;
  clientEventBus = events.EventBus();
  clientEventBus
      ?.on<DisconnectOnNoPingResponse>()
      .listen(disconnectOnNoPingResponse);
  clientEventBus
      ?.on<DisconnectOnNoMessageSent>()
      .listen(disconnectOnNoMessageSent);
  connectionHandler = SynchronousMqttBrowserConnectionHandler(clientEventBus,
      maxConnectionAttempts: maxConnectionAttempts,
      reconnectTimePeriod: connectTimeoutPeriod);
  return await super.connect(username, password);
}