Dart async、yield 和异常处理

Question

如果我有嵌套的 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

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 流的错误成为循环中的错误。然后它会被捕获，你会打印“崩溃”。

TL;DR: 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

Dart async、yield 和异常处理

Dart async, yield and exception handling

dart

dart-stream

Dart async*、yield* 和异常处理

Dart async*, yield* and exception handling

dart

dart-stream

Dart async、yield 和异常处理

Dart async, yield and exception handling