如何向dart流添加超时

import 'dart:async';

void main() {
  // 创建一个模拟的异步操作，返回一个Future
  Future<String> fetchData() async {
    await Future.delayed(Duration(seconds: 2)); // 模拟耗时操作
    return 'Data fetched successfully!';
  }

  // 创建一个流控制器
  StreamController<String> controller = StreamController();

  // 启动一个定时器，设置超时时间为3秒
  Timer timer = Timer(Duration(seconds: 3), () {
    controller.addError('Timeout occurred!'); // 在超时后向流添加错误信息
    controller.close(); // 关闭流
  });

  // 使用timeout方法为流添加超时
  controller.stream.timeout(Duration(seconds: 3), onTimeout: (event) {
    controller.addError('Timeout occurred!'); // 在超时后向流添加错误信息
    controller.close(); // 关闭流
  }).listen((data) {
    print(data); // 处理流中的数据
    timer.cancel(); // 取消定时器
  }, onError: (error) {
    print(error); // 处理流中的错误信息
    timer.cancel(); // 取消定时器
  });

  // 启动异步操作，并将结果添加到流中
  fetchData().then((data) {
    controller.add(data);
    controller.close(); // 关闭流
  });
}