subscribe method

  1. @override
Future<String> subscribe({
  1. required SubscribeOptions options,
})
override

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];
}