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