Dart 中如何转换 Stream？

推荐答案

在 Dart 中，可以通过多种方式转换 Stream，常用的方法包括使用 map、where、expand、asyncMap 等操作符。以下是一个简单的示例，展示如何使用 map 和 where 来转换 Stream：

// www.javascriptcn.com code example
import 'dart:async';

void main() async {
  // 创建一个简单的 Stream
  Stream<int> stream = Stream.fromIterable([1, 2, 3, 4, 5]);

  // 使用 map 转换 Stream 中的每个元素
  Stream<String> mappedStream = stream.map((int value) => 'Number: $value');

  // 使用 where 过滤 Stream 中的元素
  Stream<int> filteredStream = stream.where((int value) => value > 2);

  // 监听转换后的 Stream
  mappedStream.listen((String value) {
    print('Mapped: $value');
  });

  filteredStream.listen((int value) {
    print('Filtered: $value');
  });
}

本题详细解读

1. map 操作符

map 操作符用于将 Stream 中的每个元素转换为另一种类型。它接受一个函数作为参数，该函数定义了如何转换每个元素。在上面的示例中，map 将 int 类型的元素转换为 String 类型。

2. where 操作符

where 操作符用于过滤 Stream 中的元素。它接受一个条件函数，只有满足条件的元素才会被保留在 Stream 中。在上面的示例中，where 过滤掉了所有小于等于 2 的元素。

3. asyncMap 操作符

asyncMap 类似于 map，但它允许异步转换。如果转换操作是异步的（例如，涉及到网络请求或数据库查询），可以使用 asyncMap。

Stream<String> asyncMappedStream = stream.asyncMap((int value) async {
  await Future.delayed(Duration(seconds: 1)); // 模拟异步操作
  return 'Async Number: $value';
});

4. expand 操作符

expand 操作符用于将 Stream 中的每个元素扩展为多个元素。它接受一个函数，该函数返回一个 Iterable，expand 会将每个元素展开为 Iterable 中的多个元素。

Stream<int> expandedStream = stream.expand((int value) => [value, value * 2]);

5. 其他操作符

Dart 还提供了许多其他操作符来转换 Stream，例如 take、skip、distinct 等。这些操作符可以根据具体需求灵活使用。

通过组合这些操作符，可以轻松地对 Stream 进行复杂的转换和处理。