subscribe method

  1. @override
Future<String> subscribe(
  1. String topic
)
override

Implementation

@override
Future<String> subscribe(String topic) async {
  _checkInitialized();

  pendingSubscriptions[topic] = _onSubscribe(topic);

  return await pendingSubscriptions[topic];
}