subscribe method

Future subscribe(
  1. String? correlationId
)

Implementation

Future subscribe(String? correlationId) async {
  if (_subscribed) {
    return;
  }

  // Subscribe right away
  var topic = getTopic();

  await _connection!.subscribe(topic, {'qos': _qos}, this);
}