Dart Stream的机制及编程应用详解

2023-12-21 15:53:55

什么是Stream？

在Dart中，Stream是一个异步事件源，它可以产生一系列的事件，这些事件可以是数据、错误或完成信号。Stream通常用于处理异步任务，例如网络请求、文件读取或用户输入等。

Stream如何工作？

Stream通过事件监听器来工作，当Stream产生事件时，它会通知所有监听器，监听器可以通过调用Stream的listen()方法来注册。当Stream产生事件时，监听器会收到一个通知，它可以通过回调函数来处理这个事件。

Stream<String> stream = Stream.fromIterable(['a', 'b', 'c']);

stream.listen((event) {
  print(event);
});

如何创建Stream？

Dart中创建Stream有多种方式，最常见的方式是使用Stream.fromIterable()方法，该方法可以将一个Iterable对象转换为Stream对象。

Stream<String> stream = Stream.fromIterable(['a', 'b', 'c']);

此外，还可以使用StreamController类来创建Stream，StreamController是一个可以手动添加事件的Stream对象。

final controller = StreamController<String>();

controller.sink.add('a');
controller.sink.add('b');
controller.sink.add('c');

controller.stream.listen((event) {
  print(event);
});

Stream的类型

Dart中Stream有两种类型：单播Stream和广播Stream。单播Stream只能有一个监听器，而广播Stream可以有多个监听器。

// 单播Stream
Stream<String> singleSubscriptionStream = Stream.fromIterable(['a', 'b', 'c']);

// 广播Stream
Stream<String> broadcastStream = StreamController<String>().stream;

Stream的运算符

Dart中提供了丰富的Stream运算符，这些运算符可以用来对Stream进行各种操作，例如过滤、映射、合并等。

// 过滤
Stream<String> filteredStream = stream.where((event) => event.length > 1);

// 映射
Stream<int> mappedStream = stream.map((event) => event.length);

// 合并
Stream<String> mergedStream = Stream.merge([stream1, stream2]);