event_bus 的底层就是 Dart 自带的 dart:async：用 Stream + StreamController 做“事件流”，没有用别的黑科技。
1. 核心：StreamController.broadcast
_streamController = StreamController.broadcast(sync: sync);
- StreamController：管理一条“流”，一边可以往里 add(事件)，另一边可以 listen。
- broadcast：多播流，多个监听者都能收到同一条流里的事件（普通
StreamController只允许一个 listener）。 - sync：
false（默认）：事件在本次fire()返回之后、在后续的 microtask 里再分发给监听者（异步）。true：在fire()调用时立刻同步把事件交给所有监听者。
所以 event_bus 的“总线”本质上就是：一个广播型的 StreamController。
2. 发事件：fire(event) → streamController.add(event)
void fire(event) {streamController.add(event);
}
就是把事件对象放进这条流里，所有正在监听这条流的人都会收到（在 broadcast 下）。
3. 按类型订阅：on<T>() → 对 stream 做 where + cast
Stream<T> on<T>() {if (T == dynamic) {return streamController.stream as Stream<T>;} else {return streamController.stream.where((event) => event is T).cast<T>();}
}
- 底层用的还是 同一条
streamController.stream。 where((event) => event is T)：只保留类型为T（或子类）的事件。.cast<T>()：把Stream转成Stream<T>，方便监听方拿到的就是T。
所以“按事件类型监听”没有用反射或代码生成，就是 Stream 的过滤 + 类型转换。
总结成一句话
| 概念 | 底层技术 |
|---|---|
| 事件通道 | StreamController.broadcast() 产生的一条 Stream |
| 发事件 | StreamController.add(event)，即往流里塞数据 |
| 收事件 | 对这条流 listen，即 Dart 的 Stream 订阅 |
| 按类型收 | 对同一条流做 where((e) => e is T).cast<T>() |
所以 event_bus 的底层技术就是：Dart 的 Stream + StreamController.broadcast + 按类型过滤，没有额外依赖，也没有用到 Native 或平台特有 API。