使用 await for 监听
读取到达的事件
使用 await for 监听 是 CoddyKit 上的免费 Dart Academy 课时。 这是第 1 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Dart Academy 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 Dart Academy 课程共包含 4 节课。
什么是 Stream
Stream是一系列随时间到达的值,而不是一次性全部到达。您可以把它理解为能够提供多个结果、而不只是一个结果的 Future。
流与 Future 的区别
Future 会在稍后为您提供一个值。Stream 会依次传递一系列事件,直到告知您传递完成。🌊
认识等待遍历
等待遍历循环会在事件到达时从流中读取事件。循环每执行一轮,都会取得流发出的下一个值。
await for (final value in stream) {
print(value);
}必须位于异步函数中
由于等待遍历会暂停并等待事件,因此它只能在标记为async的函数中使用。函数会暂停执行,直到下一个值准备就绪。
Future<void> show(Stream<int> s) async {
await for (final n in s) print(n);
}创建一个可监听的流
您可以使用Stream.fromIterable快速创建一个流。它会按顺序发出列表中的每个元素,非常适合用来尝试等待遍历。
final stream = Stream.fromIterable([1, 2, 3]);循环处理事件
将这个流与等待遍历结合使用后,循环会针对每个发出的值执行一次。这里会依次打印 1、2、3。
await for (final n in Stream.fromIterable([1, 2, 3])) {
print(n);
}在事件之间等待
真实的流通常会在事件之间暂停。使用等待遍历时,您的代码只需在间隔期间等待,并会在下一个值到达的瞬间继续执行。⏳
final ticks = Stream.periodic(
Duration(seconds: 1), (i) => i);循环自然结束
流发送完所有事件后,会发送一个完成信号。您的等待遍历循环会自行退出,函数也会继续执行后面的代码。
await for (final n in finiteStream) print(n);
print('Stream finished');错误会传递到循环中
如果流发出错误,该错误会正好在等待遍历所在的代码行抛出。您可以将循环放在 try/catch 中,以便妥善处理错误。
try {
await for (final n in maybeFails) print(n);
} catch (e) {
print('Caught: $e');
}break 会取消监听
在等待遍历中使用break会停止循环,并静默取消您对该流的订阅。之后您将不再接收它剩余的事件。
await for (final n in stream) {
if (n > 100) break;
}一次只能有一个监听器
一个等待遍历循环会订阅单订阅流。这种流只能读取一次,因此再次对它执行循环会抛出错误。
快速检查
测试一下您对等待遍历的了解。
回顾
您已经了解到,Stream 会随着时间传递多个值,而等待遍历会在异步函数中逐个读取这些值,直到完成。做得很好!🎉
常见问题解答
「使用 await for 监听」课时是免费的吗?
是的 — 「使用 await for 监听」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 Dart Academy 课程的其余内容,请升级到 CoddyKit PRO。 Dart Academy 课程共包含 4 节课。
「使用 await for 监听」这节课中我会学到什么?
读取到达的事件 你通过在浏览器中直接运行的动手代码来练习 Dart Academy,全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Dart Academy 需要有经验吗?
无需任何先前经验。CoddyKit 上的 Dart Academy 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 1 节课,共 4 节。
「使用 await for 监听」课时需要多长时间?
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。
我能在这节 Dart Academy 课中编写并运行代码吗?
能。每节 Dart Academy 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。
此课程中的所有课时
- 使用 await for 监听
- 单订阅流与广播流
- 转换流:map、where、take
- 使用 async* 创建流