0

如果我嵌套了 async* 流，则似乎无法捕获异常，这是违反直觉的。

一个例子：

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

4

3 回答 3

2

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

在那之后，就yield await asyncError()再也没有屈服过。在到达 , 之前，await asyncError()它本身会抛出yield错误，然后由catchwhich yield捕获该错误crash。

如果要捕获流的错误，则需要实际查看事件，而不是yield*盲目地使用来将它们全部转发，包括错误事件。

例如：

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

会使asyncStarError流中的错误成为循环中的错误。然后它会被捕获，你会打印“Crash”。

TL;DR：该yield*操作转发错误事件，它不会在本地引发它们。

于 2021-11-16T13:21:11.743 回答
0

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

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

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

于 2021-11-16T13:21:33.977 回答
0

由于 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
于 2021-11-16T13:28:43.900 回答