Flutter中如何正确关闭Bloc内创建的Stream？

当前实现的问题 #

1. 变量名不匹配：代码里存在变量名错误，比如定义的是_numCarController，但在numberStream getter、checkNumber方法和closeStreams里用的是_numberController；_yearCarController和_yearController也有同样问题，这会直接导致编译失败，必须先修正。
2. 关闭时机不符合Bloc规范：你在页面的dispose里手动调用closeStreams，但如果这个Cubit被多个页面共享，或者BlocProvider的生命周期和页面不一致，这种手动关闭的方式容易导致Stream被提前关闭或者泄漏。而且Bloc/Cubit本身提供了close生命周期方法，应该利用这个机制来管理资源。

正确的实现方式 #

1. 修正变量名并重写Cubit的close方法 #

把所有变量名统一，然后重写Cubit的close方法，在里面关闭所有StreamController。这样当BlocProvider销毁Cubit时（比如页面弹出栈，BlocProvider随页面销毁），会自动调用Cubit的close方法，无需页面手动处理。

修正后的ValidationCubit代码：

class ValidationCubit extends Cubit<ValidationState> {
  ValidationCubit() : super(ValidationInitial());

  final StreamController<String?> _numCarController =
      StreamController<String?>.broadcast();
  final StreamController<String?> _yearController =
      StreamController<String?>.broadcast();
  final StreamController<bool> _buttonController =
      StreamController<bool>.broadcast()..add(false);

  Stream<String?> get numberStream => _numCarController.stream;
  Stream<String?> get yearStream => _yearController.stream;
  Stream<bool> get buttonStream => _buttonController.stream;

  bool isNumber = false;
  bool isYear = false;

  void checkNumber(String number) {
    if (number.isEmpty) {
      isNumber = false;
      _numCarController.add('Empty');
    } else {
      isNumber = true;
      _numCarController.add(null);
    }
  }

  void checkYear(String year) {
    if (year.isEmpty) {
      isYear = false;
      _yearController.add('Empty');
    } else {
      isYear = true;
      _yearController.add(null);
    }
  }

  void checkButton() {
    _buttonController.add(isNumber && isYear);
  }

  @override
  Future<void> close() {
    _numCarController.close();
    _yearController.close();
    _buttonController.close();
    return super.close();
  }
}

2. 简化页面代码 #

页面里不需要再手动调用closeStreams，BlocProvider会自动管理Cubit的生命周期，在合适的时机调用close方法：

ValidationCubit? validationCubit;

@override
void didChangeDependencies() {
  validationCubit = BlocProvider.of<ValidationCubit>(context);
  super.didChangeDependencies();
}

@override
Widget build(BuildContext context) {
  // ... 原有代码
}

额外建议 #

• 如果你不需要广播流（多个订阅者），可以去掉.broadcast()，普通StreamController更高效。
• 考虑使用BehaviorSubject（来自rxdart库）替代原生StreamController，它能保留最新的事件，适合表单验证场景，订阅者能立即拿到当前的验证状态。

内容的提问来源于stack exchange，提问作者Max