connect method

Future<bool> connect({
  1. required String host,
  2. int port = 4222,
  3. int? timeout,
  4. ConnectOption? connectOption,
  5. bool? retryReconnect,
  6. int? retryInterval,
  7. String? clientID,
  8. String? clusterID,
  9. int? pingInterval,
  10. int? pingMaxAttempts,
})

Implementation

Future<bool> connect({
  required String host,
  int port = 4222,
  int? timeout,
  nats.ConnectOption? connectOption,
  bool? retryReconnect,
  int? retryInterval,
  String? clientID,
  String? clusterID,
  int? pingInterval,
  int? pingMaxAttempts,
}) async {
  this.host = host;
  this.port = port;

  if (clientID != null) {
    _clientID = clientID;
  }

  if (retryReconnect != null) {
    this.retryReconnect = retryReconnect;
  }

  if (pingMaxAttempts != null) {
    this.pingMaxAttempts = pingMaxAttempts;
  }

  if (connectOption != null) {
    this.connectOption = connectOption;
  }

  if (retryInterval != null) {
    this.retryInterval = retryInterval;
  }

  if (clusterID != null) {
    this.clusterID = clusterID;
  }

  if (pingInterval != null) {
    this.pingInterval = pingInterval;
  }

  if (timeout != null) {
    this.timeout = timeout;
  }

  return await _connect();
}