subscribe method

int? subscribe(
  1. String topic, [
  2. dynamic qos = CommunicatorQos.atLeastOnce
])

Implementation

int? subscribe(String topic, [qos = CommunicatorQos.atLeastOnce]) {
  if (communicator == null) {
    _log.warning("Can't subscribe before connect()");
    return null;
  }
  return communicator!.subscribe(topic, qos);
}