@protected Future<void> clearListeners() async { // ignore: unawaited_futures _controller?.close(); if (_isBusy != null) { await _isBusy!.future; } _listeners.clear(); }