connect method

Future<MqttCommunicator> connect({
  1. required String host,
  2. dynamic port = 1883,
  3. dynamic secure = false,
  4. String? username,
  5. String? password,
})

Implementation

Future<MqttCommunicator> connect({
  required String host,
  port = 1883,
  secure = false,
  String? username,
  String? password,
}) async {
  final communicator = MqttCommunicator(
    server: host,
    port: port,
    username: username,
    password: password,
    secure: secure,
  );

  await communicator.connect();
  return communicator;
}