subscribe method

@override Future<String> subscribe({ required String topic, })

Implementation

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

  core.logger.i('[$runtimeType] subscribe, $topic');

  pendingSubscriptions[topic] = _onSubscribe(topic);

  return await pendingSubscriptions[topic];
}