Flutter Bloc中emit.onEach如何处理流结束、取消与错误？

在Bloc里用emit.onEach或者forEach的时候，确实没法直接拿到onDone、错误和取消的回调，要在这些时机emit新状态，可以试试下面两种方案：

方案一：用广播流兼顾多监听场景 #

如果你需要同时让Bloc处理数据和监听流的生命周期事件，转成广播流是可行的，而且能覆盖所有触发时机：

final broadcastStream = stream.asBroadcastStream();

// 单独监听流的错误和结束事件
final subscription = broadcastStream.listen(
  (_) {}, // 数据处理交给emit.onEach，这里留空就行
  onError: (error, stackTrace) {
    emit(YourErrorState(error: error)); // 错误时发送错误状态
  },
  onDone: () {
    emit(YourDoneState()); // 流正常结束发送完成状态
  },
);

try {
  // 用emit.onEach处理流数据
  await emit.onEach(
    broadcastStream,
    onData: (data) {
      emit(YourDataState(data: data));
    },
  );
} finally {
  // 不管是主动取消订阅还是Bloc销毁，都会走到这里
  emit(YourCancelledState());
  await subscription.cancel(); // 手动取消订阅，避免内存泄漏
}

方案二：用await for简化实现 #

如果不需要多订阅的场景，直接用await for循环处理流，代码更简洁，同样能覆盖所有情况：

try {
  await for (final data in stream) {
    emit(YourDataState(data: data));
  }
  // 流正常走完会到这里，发送完成状态
  emit(YourDoneState());
} catch (error, stackTrace) {
  // 捕获流抛出的错误，发送错误状态
  emit(YourErrorState(error: error));
} finally {
  // 不管是正常结束、错误还是取消订阅，都会触发这里
  emit(YourCancelledState());
}

注意点 #

• 广播流的作用是支持多个订阅（emit.onEach和我们自己的listen各占一个订阅），单订阅流没法同时被多个监听，会报错。
• finally块一定要处理订阅取消，避免内存泄漏。
• 替换代码里的YourDataState、YourDoneState这些为你实际的状态类。

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