subscribe method

Implementation

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

  final topic = options.topic;
  core.logger.i('[$runtimeType] subscribe, $topic');
  pendingSubscriptions[topic] = _onSubscribe(options);

  return await pendingSubscriptions[topic];
}