What are the different types of streams in Dart?

在Dart中，流（Streams）是用来处理异步事件序列的一个非常重要的概念。流可以用来读取从文件或网络获取的数据，处理用户输入等等。Dart中主要有两种类型的流：单订阅流和广播流。

1. 单订阅流（Single subscription streams）

单订阅流是最普通的流类型，它允许一个单一的监听者（listener）进行数据的监听。这意味着一旦你开始监听流，你不能再让另一个监听者加入。如果你尝试添加另一个监听者，程序将会抛出异常。单订阅流非常适合需要顺序处理数据的场景，例如文件读取。

例子：

dart
import 'dart:async';
import 'dart:io';

void main() {
  // 打开文件作为流
  Stream<List<int>> stream = File('example.txt').openRead();

  // 监听数据事件
  stream.listen((data) {
    print('Received data: ${String.fromCharCodes(data)}');
  }, onDone: () {
    print('File is now fully read.');
  }, onError: (e) {
    print('Error occurred: $e');
  });
}

2. 广播流（Broadcast streams）

广播流可以被多个监听者同时监听。这种类型的流非常适合事件监听，比如UI事件或者其他应用程序的状态变化。广播流不保证监听者能接收到数据的顺序，因此它们通常用在监听者之间不需要数据顺序的场景中。

例子：

dart
import 'dart:async';

void main() {
  // 创建一个广播流控制器
  var streamController = StreamController.broadcast();

  // 监听流
  streamController.stream.listen((data) {
    print('Listener 1: $data');
  });

  streamController.stream.listen((data) {
    print('Listener 2: $data');
  });

  // 添加数据到流中
  streamController.add('Hello, World!');
  streamController.add('Another event');

  // 关闭流
  streamController.close();
}

总结

在选择使用单订阅流还是广播流时，重要的是要考虑你的应用场景是否需要数据的顺序性或者是否需要多个消费者。每种类型的流都有其用例和优势，正确地选择可以帮助你更高效地处理数据和事件。