Dart 中 Stream 的常用操作符有哪些？

推荐答案

在 Dart 中，Stream 提供了多种操作符来处理异步数据流。以下是一些常用的操作符：

1. map: 对 Stream 中的每个元素进行转换。
2. where: 过滤 Stream 中的元素，只保留满足条件的元素。
3. take: 只取 Stream 中的前 n 个元素。
4. skip: 跳过 Stream 中的前 n 个元素。
5. distinct: 过滤掉 Stream 中连续重复的元素。
6. listen: 监听 Stream 中的事件。
7. asyncMap: 对 Stream 中的每个元素进行异步转换。
8. expand: 将 Stream 中的每个元素扩展为多个元素。
9. reduce: 将 Stream 中的所有元素合并为一个值。
10. fold: 类似于 reduce，但可以指定初始值。
11. toList: 将 Stream 中的所有元素收集到一个列表中。
12. toSet: 将 Stream 中的所有元素收集到一个集合中。
13. timeout: 设置 Stream 的超时时间。
14. debounce: 在 Stream 中元素停止发射一段时间后，才发射最后一个元素。
15. throttle: 在指定时间间隔内只发射一个元素。

本题详细解读

map 操作符

map 操作符用于对 Stream 中的每个元素进行转换。它接受一个函数作为参数，该函数将每个元素转换为另一个值。

stream.map((event) => event * 2).listen(print);

where 操作符

where 操作符用于过滤 Stream 中的元素，只保留满足条件的元素。

stream.where((event) => event > 5).listen(print);

take 操作符

take 操作符用于只取 Stream 中的前 n 个元素。

stream.take(3).listen(print);

skip 操作符

skip 操作符用于跳过 Stream 中的前 n 个元素。

stream.skip(2).listen(print);

distinct 操作符

distinct 操作符用于过滤掉 Stream 中连续重复的元素。

stream.distinct().listen(print);

listen 操作符

listen 操作符用于监听 Stream 中的事件。它是 Stream 的核心操作符之一。

stream.listen((event) {
  print('Event: $event');
});

asyncMap 操作符

asyncMap 操作符用于对 Stream 中的每个元素进行异步转换。

stream.asyncMap((event) async {
  return await someAsyncFunction(event);
}).listen(print);

expand 操作符

expand 操作符用于将 Stream 中的每个元素扩展为多个元素。

stream.expand((event) => [event, event * 2]).listen(print);

reduce 操作符

reduce 操作符用于将 Stream 中的所有元素合并为一个值。

stream.reduce((value, element) => value + element).then(print);

fold 操作符

fold 操作符类似于 reduce，但可以指定初始值。

stream.fold(0, (value, element) => value + element).then(print);

toList 操作符

toList 操作符用于将 Stream 中的所有元素收集到一个列表中。

stream.toList().then((list) => print(list));

toSet 操作符

toSet 操作符用于将 Stream 中的所有元素收集到一个集合中。

stream.toSet().then((set) => print(set));

timeout 操作符

timeout 操作符用于设置 Stream 的超时时间。

stream.timeout(Duration(seconds: 5)).listen(print);

debounce 操作符

debounce 操作符用于在 Stream 中元素停止发射一段时间后，才发射最后一个元素。

stream.debounce(Duration(seconds: 1)).listen(print);

throttle 操作符

throttle 操作符用于在指定时间间隔内只发射一个元素。

stream.throttle(Duration(seconds: 1)).listen(print);