@override Future<String> subscribe({required String topic}) async { _checkInitialized(); pendingSubscriptions[topic] = _onSubscribe(topic); return await pendingSubscriptions[topic]; }