处理 Stream1.当需要从 Stream 中获取数据值时, 可以通过一下两种方式:
使用 async 和 一个 异步循环 (await for)。
使用 Stream API,
2.异步for循环的使用形式:
await for (varOrType identifier in expression) {
// Executes each time the stream emits a value.
}
上面表达式返回的值必须是 Stream 类型。 执行流程如下:
1).等待,直到流发出一个值。
2).执行 for 循环体,将变量设置为该发出的值。
3).重复1和2,直到关闭流。
3.使用 break 或者 return 语句可以停止接收 stream 的数据, 这样就跳出了 for 循环, 并且从 stream 上取消注册。