如何在Stream中抛出异常并让Widget树的AsyncValue捕获？

核心原因 #

直接在async*生成器中throw异常，会导致生成器本身抛出未捕获异常触发App红屏；而Stream.error()需要通过Riverpod的StreamProvider正确处理，才能将错误包装为AsyncValue.error状态，被你的AsyncValueWidget捕获。

解决方案步骤 #

1. 修正Stream的错误抛出方式 #

在async*函数中，不要直接throw，而是使用yield* Stream.error()发送错误事件，让Stream将错误作为事件传递而非直接崩溃：

Stream<T> function() async* {
  await Future.delayed(const Duration(milliseconds: 500));

  switch (condition) {
    case condition1:
      yield value1;
      break;
    case condition2:
      yield value2;
      break;
    case condition3:
      // 正确发送错误事件
      yield* Stream.error(
        Exception('You should not be able to call this function under this condition'),
      );
      break;
    case condition4:
      yield null;
      break;
  }
}

2. 用StreamProvider包裹你的Stream #

Riverpod的StreamProvider会自动监听Stream的所有事件（包括错误），并将其转换为AsyncValue状态：

// 定义你的StreamProvider
final myDataStreamProvider = StreamProvider<T>((ref) {
  final repository = MyRepository(); // 你的仓库实例
  return repository.function();
});

3. 在Widget中正确监听Provider #

使用ref.watch获取AsyncValue实例，传入你的AsyncValueWidget：

class MyPage extends ConsumerWidget {
  @override
  Widget build(BuildContext context, WidgetRef ref) {
    final asyncData = ref.watch(myDataStreamProvider);
    return AsyncValueWidget<T>(
      value: asyncData,
      data: (data) {
        // 根据数据渲染UI
        return Text(data?.toString() ?? '无数据');
      },
    );
  }
}

4. 统一捕获Stream内部异常（可选） #

如果Stream内部有其他可能抛出异常的异步操作，建议用try/catch包裹，统一将错误通过Stream.error发送：

Stream<T> function() async* {
  try {
    await Future.delayed(const Duration(milliseconds: 500));
    // 其他可能抛出异常的操作
    switch (condition) {
      // ... 分支逻辑
    }
  } catch (e, stackTrace) {
    // 捕获所有异常并转为Stream错误事件
    yield* Stream.error(e, stackTrace);
  }
}

为什么之前的方式无效？ #

• 直接throw：在async*生成器中抛出异常属于未捕获异常，会绕过Riverpod的错误处理逻辑，直接触发App红屏。
• Stream.error()未生效：如果没有通过StreamProvider监听Stream，Riverpod无法将错误事件转换为AsyncValue.error，自然无法被AsyncValueWidget的error回调处理。

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