理解 Stream：Flutter 中的实时数据流

Android

2023-11-02 23:33:16

流 (Stream) 是 Flutter 中一种强大的工具，用于处理异步数据流。与 Future 不同，它是一种单向数据流，可以持续提供数据，直到它被取消。在本指南中，我们将深入探讨 Stream 的概念，并通过示例了解如何使用它们。

Stream 的概念

Stream 是一个对象，它可以随时间发出事件。这些事件可以是数据更新、错误或完成通知。Stream 只能向其监听者提供数据，并且监听者可以随时取消订阅。

使用 Stream

要使用 Stream，你需要执行以下步骤：

创建一个 Stream。
订阅该 Stream。
处理收到的事件。

创建 Stream

有两种主要方法可以创建 Stream：

异步生成器： 使用 async* 定义一个函数，并使用 yield 关键字返回事件。
流控制器： 使用 StreamController 类创建流控制器，它提供了用于管理流生命周期的接口。

订阅 Stream

要订阅 Stream，可以使用 listen() 方法。此方法接受一个事件处理程序作为参数，该处理程序将在收到事件时调用。

处理事件

事件处理程序可以处理三种类型的事件：

数据事件： 包含流中发出的实际数据。
错误事件： 表示流中发生的错误。
完成事件： 指示流已完成且不会发出更多事件。

Stream 的优势

使用 Stream 具有以下优势：

实时数据更新： Stream 允许应用程序接收实时数据更新，从而实现对动态数据源的响应。
异步编程： Stream 使用异步编程模型，使应用程序可以避免阻塞操作并保持 UI 响应。
取消订阅： 监听者可以随时取消订阅 Stream，从而释放资源并防止内存泄漏。

Stream 的示例

以下是一个示例，展示了如何使用 Stream 来处理来自网络 API 的数据：

import 'dart:async';

Future<String> fetchUserData() async {
  // 模拟从服务器获取数据
  return Future.delayed(
      Duration(seconds: 2), () => '{"name": "John Doe", "age": 30}');
}

void main() async {
  Stream<String> userDataStream =
      fetchUserData().asStream().handleError((error) => print(error));

  userDataStream.listen((data) {
    print('Received data: $data');
  });
}