如何让Broadcast Stream新监听器获取已发送的值（支持多监听器）

哈哈，这个问题我之前也踩过坑！普通的broadcast类型StreamController本身不会帮你缓存已经发送的事件——它就像个实时广播，只有在你打开收音机（订阅）之后，才能听到之后的节目（新事件），之前的内容早就飘走了。

要实现让后续订阅的监听器也能拿到之前发过的值，还支持多监听器，给你两个靠谱的方案：

方案一：用BehaviorSubject（最省心） #

RxDart里的BehaviorSubject简直就是为这个场景量身定做的！它会自动缓存最新的一个事件，只要有新的监听器订阅，立刻就把这个最新事件推过去，而且它本身就是支持多订阅的广播流，完全符合你的需求。

具体操作步骤：

1. 先在pubspec.yaml里加上RxDart依赖：

dependencies:
  rxdart: ^0.27.7 # 可以去pub.dev查看最新版本号

2. 把原来的StreamController换成BehaviorSubject就行：

import 'package:rxdart/rxdart.dart';

// 初始化BehaviorSubject
final BehaviorSubject<int> listener = BehaviorSubject<int>();

// 先发送值7
listener.add(7);

// 之后再订阅，马上就能收到7
listener.stream.listen((val) { print(val); }); // 控制台会输出7

// 后续再发新值，所有已订阅的监听器都能收到
listener.add(10); // 输出10

是不是超简单？而且它还自带很多其他实用功能，比如可以设置初始值、处理错误事件之类的。

方案二：自己实现带缓存的广播流（不想加依赖的话） #

如果不想引入第三方库，也可以手动写个简单的缓存逻辑，核心思路就是自己存住最新的事件，当新订阅者来的时候，先把缓存的事件发给他，再接着发后续的新事件。

代码示例：

class CachedBroadcastStream<T> {
  final StreamController<T> _innerController = StreamController<T>.broadcast();
  T? _latestEvent;

  // 发送事件时，先缓存再发送
  void add(T event) {
    _latestEvent = event;
    _innerController.add(event);
  }

  // 获取流的时候，先把缓存的事件（如果有的话）发出去，再接原流
  Stream<T> get stream {
    final cachedStream = _latestEvent != null 
        ? Stream<T>.value(_latestEvent!) 
        : Stream<T>.empty();
    return cachedStream.followedBy(_innerController.stream);
  }

  // 记得关闭流，防止内存泄漏
  void close() => _innerController.close();
}

使用的时候和原来差不多：

final CachedBroadcastStream<int> listener = CachedBroadcastStream<int>();

listener.add(7);

// 订阅后直接收到7
listener.stream.listen((val) { print(val); }); // 输出7

// 再发新值，监听器也能收到
listener.add(15); // 输出15

这个自定义类同样支持多监听器，每个新订阅的都会先拿到缓存的最新值。

额外小提示 #

如果你需要缓存不止一个历史事件（比如最近3个），可以试试RxDart的ReplaySubject，它能指定缓存的事件数量，新订阅者会一次性收到所有缓存的事件，非常好用。

不管用哪种方案，一定要记得在不需要这个流的时候调用close()，不然容易造成内存泄漏哦！

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