@override Future<void> unsubscribe() async { if (_active) { _active = false; if (_onUnsubscribe != null) { await _onUnsubscribe!(); } } }