Flutter中StreamController结合Riverpod StreamProvider初始数据未接收问题

针对你遇到的Riverpod StreamProvider无法接收StreamController初始假数据的问题，这里提供两个无需额外依赖、也不需要人为延迟的原生实现方案：

方案1：异步触发初始数据发送 #

问题根源在于同步发送初始数据时，Riverpod的订阅可能尚未完全建立，导致数据丢失。通过Future.microtask将数据发送推迟到当前事件循环的微任务队列，确保订阅完成后再推送初始数据：

class MyService {
  final StreamController<List<String>> _controller =
      StreamController.broadcast();

  List<String> _dataFetched = ['dummy_data'];

  Stream<List<String>> get dataStream => _controller.stream;

  MyService() {
    _controller.onListen = () {
      print('Someone started listening');
      // 利用微任务确保订阅完成后发送初始数据
      Future.microtask(() => _controller.sink.add(_dataFetched));
    };
  }

  void fetch() async {
    _dataFetched = await Future.delayed(Duration(seconds: 2), () => ['new_data']);
    _controller.sink.add(_dataFetched);
  }
}

方案2：合并初始值流与更新流 #

直接在dataStream的getter中，将初始数据作为独立流与控制器的更新流合并，让所有订阅者都能先拿到初始数据，再接收后续更新：

class MyService {
  final StreamController<List<String>> _controller =
      StreamController.broadcast();

  List<String> _dataFetched = ['dummy_data'];

  Stream<List<String>> get dataStream => Stream.concat([
        // 先推送当前的初始数据
        Stream.value(_dataFetched),
        // 再转发后续的更新数据流
        _controller.stream,
      ]);

  MyService() {
    _controller.onListen = () {
      print('Someone started listening');
    };
  }

  void fetch() async {
    _dataFetched = await Future.delayed(Duration(seconds: 2), () => ['new_data']);
    _controller.sink.add(_dataFetched);
  }
}

这两个方案都能保证Riverpod的StreamProvider订阅时立即接收到初始假数据，同时不影响后续fetch方法获取的新数据推送。

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