Flutter中Stream与Future是什么关系？

发布于 1周前 作者 yuanlaile 来自 Flutter

Flutter中Stream与Future是什么关系？

在 Dart 中，Stream 和 Future 都是用于处理异步操作的类型，但它们在用途和行为上有明显的区别。

简单区别

  • Future：表示一次性异步操作，在操作完成后会返回单一结果。
  • Stream：表示连续的异步事件序列，可以在不同的时间点返回多个结果。

关系与适用场景

  • 单次 vs. 多次异步事件

    • Future 适用于一次性异步事件，比如 HTTP 请求、数据库查询或文件读取。
    • Stream 适用于多次异步事件，比如文件逐行读取、实时数据流、用户输入事件等。

  • 结果的数量

    • Future 只返回一个结果（成功或失败）。
    • Stream 可以返回一系列结果，可能是无限的，比如网络数据流或传感器数据。

  • 用法

    • Future 使用 await 关键字来等待结果。
    • Stream 可以使用 await for 或 listen 来处理每个事件。

示例代码

Future 示例

import 'dart:async';

Future<String> fetchData() async {
  // 模拟网络请求，延时2秒
  await Future.delayed(Duration(seconds: 2));
  return "Data fetched from the server";
}

void main() async {
  String result = await fetchData();
  print(result);  // 输出: Data fetched from the server
}

Stream 示例

import 'dart:async';

Stream<int> generateNumbers() async* {
  for (int i = 0; i < 5; i++) {
    await Future.delayed(Duration(seconds: 1));
    yield i;
  }
}

void main() {
  generateNumbers().listen((number) {
    print(number);  // 每秒输出一个数字: 0, 1, 2, 3, 4
  });
}

将 Future 转为 Stream

import 'dart:async';

Future<String> fetchData() async {
  await Future.delayed(Duration(seconds: 2));
  return "Data fetched from the server";
}

void main() async {
  Stream<String> stream = Stream.fromFuture(fetchData());
  stream.listen((data) {
    print(data);  // 输出: Data fetched from the server
  });
}

总结

  • Future：单次异步操作，返回一个值或错误。
  • Stream：多次异步操作的序列，适合连续事件流。

通过上述示例，可以清楚地看到 Future 和 Stream 在处理异步操作时的不同用途和行为。Future 更适合一次性异步操作，而 Stream 则适用于需要处理一系列连续异步事件的场景。


更多关于Flutter中Stream与Future是什么关系？的实战系列教程也可以访问 https://www.itying.com/category-92-b0.html

Harmonyos Next教程
1 回复

更多关于Flutter中Stream与Future是什么关系？的实战系列教程也可以访问 https://www.itying.com/category-92-b0.html


在Flutter和Dart编程环境中，Stream 和 Future 是处理异步操作的两个核心概念，它们各自有不同的用途和特性，但在某些场景下可以协同工作。以下是关于它们关系的详细解释，并附有相关代码示例。

Future

Future 用于表示一个异步操作的结果，这个操作将来会完成并返回一个值（或者抛出一个异常）。Future 是一次性的，即它只能有一个结果，一旦结果确定（无论是成功还是失败），就不能再改变。

示例代码：

Future<int> fetchData() async {
  // 模拟一个异步操作，比如网络请求
  await Future.delayed(Duration(seconds: 2));
  return 42; // 返回结果
}

void main() {
  fetchData().then((result) {
    print('Result: $result');
  }).catchError((error) {
    print('Error: $error');
  });
}

Stream

Stream 用于表示一系列异步事件，这些事件可以随时间连续产生。Stream 允许监听者（Listener）注册回调，以便在事件发生时接收通知。与 Future 不同，Stream 可以产生多个值，并且可以是无限的。

示例代码：

import 'dart:async';

Stream<int> generateNumbers() {
  return Stream.fromIterable([1, 2, 3, 4, 5]);
}

void main() {
  generateNumbers().listen((number) {
    print('Number: $number');
  }, onError: (error) {
    print('Error: $error');
  }, onDone: () {
    print('Done');
  });
}

Stream 与 Future 的关系

虽然 Stream 和 Future 有不同的用途，但它们可以互相转换，以适应不同的需求。

Future 转 Stream

可以使用 Stream.fromFuture 将 Future 转换为 Stream。这在需要将 Future 结果作为 Stream 事件处理时非常有用。

Future<int> fetchData() async {
  await Future.delayed(Duration(seconds: 2));
  return 42;
}

void main() {
  Stream<int> dataStream = Stream.fromFuture(fetchData());
  dataStream.listen((result) {
    print('Stream Result: $result');
  }, onError: (error) {
    print('Stream Error: $error');
  });
}

Stream 转 Future

可以使用 Stream.last 或 Stream.first 将 Stream 转换为 Future。这在需要等待 Stream 发出特定事件（如最后一个或第一个事件）时非常有用。

Stream<int> generateNumbers() {
  return Stream.fromIterable([1, 2, 3, 4, 5]);
}

void main() {
  Future<int> lastNumber = generateNumbers().last;
  lastNumber.then((result) {
    print('Last Number: $result');
  });
}

总结

Future 和 Stream 在Flutter和Dart中都是处理异步操作的重要工具。Future 用于表示单个异步操作的结果，而 Stream 用于表示一系列异步事件。它们可以互相转换，以适应不同的编程需求。理解它们的特性和用法，对于编写高效、可维护的异步代码至关重要。

回到顶部