@override Future<void> unsubscribe() async { if (_subscriptions.isNotEmpty) { await Future.wait(_subscriptions.map((sub) => sub.unsubscribe())); _subscriptions.clear(); } }