Flutter Bloc能否正确处理多次快速事件发射？实际应用该如何优化？

一、实际场景是否会出现？ #

这种情况绝非仅测试场景，实际应用中很常见：比如用户快速点击提交按钮（未做防抖处理）、表单提交时因网络延迟重复触发、或者某些自动触发的逻辑短时间内多次发送事件，都会导致连续分发同一事件的情况。

二、为什么会多次发射Loading状态？ #

Bloc的事件处理是队列式顺序执行的：每一个add的事件都会进入事件队列，等待前一个事件处理完成后再执行。你的_onAddCategory处理器中，每收到一个事件就会先emit(CategoryLoading())，因此连续的事件会依次触发Loading状态，即使当前已经处于Loading状态。

三、如何解决：确保事件处理+避免冗余状态 #

1. UI层防抖（防止重复触发事件） #

如果业务上不需要处理重复的用户操作（比如重复点击提交），可以在UI层添加防抖逻辑，短时间内只触发一次事件：

Timer? _debounceTimer;

void handleAddCategory() {
  _debounceTimer?.cancel();
  // 300ms内重复点击会取消之前的定时器，只保留最后一次
  _debounceTimer = Timer(const Duration(milliseconds: 300), () {
    bloc.add(AddCategoryEvent(categoryMap: categoryModelMap));
  });
}

适用场景：用户误操作导致的重复触发，减少不必要的事件进入Bloc。

2. Bloc内部过滤重复Loading状态 #

如果需要处理所有事件，但不想重复发射Loading状态，可以在事件处理器中判断当前状态，仅当非Loading时才发射：

Future<void> _onAddCategory(AddCategoryEvent event, Emitter<CategoryState> emit) async {
  // 仅当前状态不是Loading时，才发射Loading
  if (state is! CategoryLoading) {
    emit(CategoryLoading());
  }
  
  try {
    await _categoryRepository.addCategory(event.categoryMap);
    emit(CategorySuccess());
  } catch (e) {
    emit(CategoryFailure());
  }
}

效果：连续事件只会在第一个事件触发时发射一次Loading，后续事件不会重复发射，但所有事件的业务逻辑（调用addCategory）依然会执行。

3. 事件流去重（合并重复事件） #

如果相同参数的事件不需要重复处理，可以通过transformEvents方法对事件流去重，只保留最新的事件：

@override
Stream<Transition<CategoryEvent, CategoryState>> transformEvents(
  Stream<CategoryEvent> events,
  TransitionFunction<CategoryEvent, CategoryState> transitionFn,
) {
  return super.transformEvents(
    events.distinct((previous, next) {
      // 判断两个AddCategoryEvent是否参数相同，相同则视为重复事件
      if (previous is AddCategoryEvent && next is AddCategoryEvent) {
        return previous.categoryMap == next.categoryMap;
      }
      return false;
    }),
    transitionFn,
  );
}

适用场景：重复的事件不会带来新的业务结果，比如多次添加同一分类，只需要处理最后一次即可。

4. 并发模式控制（Bloc 8.0+） #

Bloc 8.0+支持并发模式配置，比如使用restartable模式，当新事件到来时取消之前未完成的事件处理：

class CategoryBloc extends Bloc<CategoryEvent, CategoryState> {
  CategoryBloc() : super(CategoryInitial()) {
    on<AddCategoryEvent>(
      _onAddCategory,
      // 新事件到来时取消之前的处理，只执行最新的事件
      transformer: restartable(),
    );
  }
  
  // ... 处理器代码
}

注意：这种方式会丢弃之前未完成的事件处理，如果业务需要所有事件都被处理，不建议使用；适合只需要最新结果的场景。

四、为什么需要关注这个问题？ #

多次发射Loading状态可能引发以下问题：

• UI层多次刷新，比如loading动画频繁闪烁，影响用户体验；
• 如果UI根据Loading状态做交互控制（比如禁用按钮），重复的状态发射可能导致按钮状态异常；
• 不必要的状态更新会增加Bloc的状态流转开销。

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