新版Flutter BLoC包如何正确实现错误处理？

你当前在事件处理器内写try/catch捕获错误、发射ErrorState的逻辑本身是完全正确的，符合BLoC单向数据流的设计原则，问题只是重复代码过多导致可读性差，并不是实现思路错误。

为什么不能在onError钩子中直接发射状态 #

bloc 8.0及以上版本做了并发安全设计：状态发射的emitter是和单个事件的处理生命周期严格绑定的，事件处理完成后对应的emitter就会被标记为失效。onError作为全局错误捕获钩子，设计定位就是做日志打印、错误上报这类无状态副作用，本身不提供事件作用域内的合法emitter，强行在这个位置发射状态会引发状态不一致、内存泄漏问题，不符合框架规范。

减少重复try/catch的通用实现 #

最通用的做法是把重复的加载态发射、try/catch逻辑抽成通用包装方法，所有事件处理器复用这套逻辑即可，不需要每个方法都重复写样板代码：

// 可放在Bloc基类中作为通用工具方法
Future<void> runAsyncTask<T>(
  Future<T> Function() asyncTask,
  Emitter<ExerciseState> emit, {
  required ExerciseState Function(T successData) onSuccess,
  ExerciseState Function(Object error)? onCustomError,
}) async {
  // 统一发射加载态
  emit(ExerciseLoadingState());
  try {
    final result = await asyncTask();
    emit(onSuccess(result));
  } catch (err) {
    // 统一打错误日志
    log(err.toString());
    // 支持自定义错误态，没有配置就用默认错误态
    emit(onCustomError?.call(err) ?? const ExerciseErrorState());
  }
}

抽离后原来的事件处理器可以简化成下面的写法，完全去掉重复的try/catch样板：

void _startExercise(ExerciseStarted event, Emitter<ExerciseState> emit) async {
  await runAsyncTask(
    () => _repository.doSomething(),
    emit,
    onSuccess: (data) => ExerciseLoadedState(something: data),
  );
}

补充说明 #

• 全局的BlocObserver.onError可以作为兜底错误捕获入口，只用来做全局日志、上报逻辑，不要在这里处理状态发射。
• 如果部分事件不需要加载态、或者有特殊的错误处理逻辑，可以在调用通用包装方法时传入自定义参数覆盖默认逻辑，灵活度和手写try/catch完全一致。

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