Dart StreamController Broadcast()

在Dart中，StreamController被用于创建数据流，并支持向这些数据流发送事件数据。 Dart官方文档中对StreamController的定义如下：

A StreamController is a way to create a stream, and to add data into that stream.

StreamController提供两个重要的方法：

• Stream<T> stream: 返回一个流(Stream)。
• StreamSink<T> sink: 返回一个Sink对象，用于添加数据到队列中。

在Dart中，StreamController还支持使用broadcast方法来创建广播流。

创建广播流

使用StreamController的broadcast()方法可以创建一个广播数据流。广播数据流可以被多个订阅者同时订阅，每个订阅者都可以独立地接收来自数据流的事件数据。创建一个广播流的代码如下：

final StreamController<int> _controller = StreamController<int>.broadcast();

在上面的代码中，我们创建了一个类型为int的广播数据流，并将其保存在名为_controller的StreamController对象中。

添加事件数据到流中

使用StreamSink的add方法，我们可以将事件数据添加到StreamController的队列中。具体方式如下：

_controller.sink.add(1);

在上面的代码中，我们将事件数据'1'添加到了名为_controller的广播数据流中。所有已经订阅了这个广播流的监听器都会接收到这个数据事件。

订阅广播数据流

我们可以通过调用stream属性获取到一个Stream流并通过调用Stream的listen方法来订阅广播数据流。具体步骤如下：

_controller.stream.listen((event) {
    // 监听数据流
    print(event);
  });

上面的代码中，我们添加了一个监听器来订阅广播流。当广播流中有数据事件时，监听器会接收到这个事件并执行相应的操作。

代码示例

下面是一个完整的示例代码，包含创建广播数据流、添加数据事件、订阅广播数据流等所有操作。

import 'dart:async';

void main() async {
  // 创建广播数据流
  final StreamController<int> _controller = StreamController<int>.broadcast();

  // 订阅广播数据流
  _controller.stream.listen((event) {
    // 监听数据流
    print(event);
  });

  // 添加数据事件到广播数据流中
  _controller.sink.add(1); // 输出 1
  _controller.sink.add(2); // 输出 2
}

以上示例中，我们创建了一个广播类型为int的数据流，在订阅该数据流之前，向数据流中添加了两个数据事件1和2。订阅后，两个数据事件都被正确地输出到控制台上。

Markdown格式的代码片段

# Dart StreamController Broadcast()

在Dart中，StreamController被用于创建数据流，并支持向这些数据流发送事件数据。使用broadcast方法可以创建广播数据流。

## 创建广播流

使用StreamController的`broadcast()`方法可以创建一个广播数据流。广播数据流可以被多个订阅者同时订阅，每个订阅者都可以独立地接收来自数据流的事件数据。创建一个广播流的代码如下：

final StreamController _controller = StreamController.broadcast();

在上面的代码中，我们创建了一个类型为int的广播数据流，并将其保存在名为_controller的StreamController对象中。

## 添加事件数据到流中

使用StreamSink的add方法，我们可以将事件数据添加到StreamController的队列中。具体方式如下：

_controller.sink.add(1);

在上面的代码中，我们将事件数据'1'添加到了名为_controller的广播数据流中。所有已经订阅了这个广播流的监听器都会接收到这个数据事件。

## 订阅广播数据流

我们可以通过调用`stream`属性获取到一个Stream流并通过调用Stream的listen方法来订阅广播数据流。具体步骤如下：

_controller.stream.listen((event) { // 监听数据流 print(event); });

上面的代码中，我们添加了一个监听器来订阅广播流。当广播流中有数据事件时，监听器会接收到这个事件并执行相应的操作。

## 代码示例

下面是一个完整的示例代码，包含创建广播数据流、添加数据事件、订阅广播数据流等所有操作。

```dart
import 'dart:async';

void main() async {
  // 创建广播数据流
  final StreamController<int> _controller = StreamController<int>.broadcast();

  // 订阅广播数据流
  _controller.stream.listen((event) {
    // 监听数据流
    print(event);
  });

  // 添加数据事件到广播数据流中
  _controller.sink.add(1); // 输出 1
  _controller.sink.add(2); // 输出 2
}

以上示例中，我们创建了一个广播类型为int的数据流，在订阅该数据流之前，向数据流中添加了两个数据事件1和2。订阅后，两个数据事件都被正确地输出到控制台上。