Dart async*、Dart*和异常处理

Question

如果我有嵌套的异步*流，异常看起来是不可捕获的，这是违反直觉的。

举个例子：

void main() {
  getString().listen(print);
}

Stream<String> getString() async* {
  try {
    yield* asyncStarError();
    yield await asyncError();
  } catch (err) {
    yield 'Crash';
  }
}

Stream<String> asyncStarError() async* {
  throw Exception('A Stream error happened');
}

Future<String> asyncError() async {
  throw Exception('A Future error happened');
}

这将输出以下内容：

Uncaught Error: Exception: A Stream error happened
Crash

因此，asyncStarError抛出的异常不会被捕获，而Future则会如期捕获。有谁能解释一下原因吗？

您可以在dartpad中观察其行为：https://dartpad.dartlang.org

Answer 1

yield*转发它生成的流中的所有事件，包括错误。因此，asyncStarError()生成一个带有错误事件的流，yield*将该错误转发给getString返回的流，然后getString.listen(print);不添加处理程序，因此该错误不会被捕获。(我猜您是在浏览器中运行这段代码，因为未捕获的错误不会使程序崩溃。)

在那之后，yield await asyncError()再也不会输出任何东西了。await asyncError()本身在到达yield之前抛出，然后该错误被catch捕获，从而生成crash。

如果您想捕获流的错误，您需要实际查看事件，而不仅仅是使用yield*盲目地转发所有事件，包括错误事件。

例如：

    await for (var _ in asyncStarError()) {
      // Wohoo, event!
    }

将使来自asyncStarError流的错误成为循环中的错误。然后它将被捕获，您将打印"Crash“。

yield*操作转发错误事件，而不是在本地引发它们。

Answer 2

不同之处在于，异步生成器( async *)异常不能通过使用try/catch包围它来捕获。

相反，您应该使用回调handleError来实现您正在寻找的行为。

更进一步，您可能会对使用runZonedGuarded感兴趣。

Answer 3

因为yield *像@lrn所说的那样转发它们，所以你可以在main中很好地捕获它们。或者在你消费它们的任何地方。

void main() {
  getString().listen(print).onError((e) => print('error caught: $e'));
}

Stream<String> getString() async* {
  try {
    yield* asyncStarError();
    yield await asyncError();
  } catch (err) {
    yield 'Crash';
  }
}

Stream<String> asyncStarError() async* {
  throw Exception('A Stream error happened');
}

Future<String> asyncError() async {
  throw Exception('A Future error happened');
}

这将打印：

error caught: Exception: A Stream error happened
Crash