Flutter实现首次与后续不同间隔的Stream定时器

你的问题出在Timer.periodic的间隔是创建时一次性确定的，后续修改isFirst不会改变已创建Timer的执行周期，所以才会一直保持2秒间隔。下面提供两种可行的实现方案：

方案一：使用Stream组合（简洁推荐） #

利用Stream.concat将首次延迟请求和后续周期请求合并，无需手动管理控制器和定时器：

Stream<List<Message>> getDataStream() {
  // 首次请求：延迟2秒后触发一次
  final firstRequest = Stream<void>.delayed(const Duration(seconds: 2));
  // 后续请求：每35秒触发一次
  final periodicRequests = Stream.periodic(const Duration(seconds: 35));
  
  // 合并流：先执行首次请求，之后持续执行周期请求
  return Stream.concat([firstRequest, periodicRequests])
      .asyncMap((_) async {
        // 替换为你的API请求逻辑
        return await _fetchMessages();
      });
}

// 模拟API请求方法
Future<List<Message>> _fetchMessages() async {
  // 这里写实际的API调用代码
  // 比如：return await apiService.getMessages();
}

方案二：手动管理StreamController（灵活可控） #

如果需要更精细的控制（比如监听取消、错误处理），可以用StreamController配合定时器实现：

StreamController<List<Message>>? _messageController;
Timer? _requestTimer;

Stream<List<Message>> getDataStream() {
  _messageController ??= StreamController<List<Message>>.broadcast(
    onListen: () {
      // 首次延迟2秒执行请求
      Future.delayed(const Duration(seconds: 2), () async {
        await _performRequest();
        // 首次请求完成后，启动35秒周期的定时器
        _requestTimer = Timer.periodic(const Duration(seconds: 35), (_) {
          _performRequest();
        });
      });
    },
    onCancel: () {
      // 取消定时器并关闭控制器，避免内存泄漏
      _requestTimer?.cancel();
      _messageController?.close();
      _requestTimer = null;
      _messageController = null;
    },
  );
  return _messageController!.stream;
}

Future<void> _performRequest() async {
  try {
    final messages = await _fetchMessages();
    _messageController?.add(messages);
  } catch (error) {
    // 处理API请求错误
    _messageController?.addError(error);
  }
}

Future<List<Message>> _fetchMessages() async {
  // 实际API请求逻辑
}

关键说明 #

• 方案一适合简单场景，代码更简洁，无需手动管理资源；
• 方案二更适合需要处理取消、错误或其他复杂逻辑的场景；
• 两种方案都能实现「首次2秒间隔，后续每35秒请求一次」的需求，避免请求过于频繁导致的报错。

内容的提问来源于stack exchange，提问作者mafortis