Dart广播Stream多监听器如何指定执行顺序优先级？

标准Dart Stream没有内置的监听器执行顺序配置能力，listen方法官方定义确实没有优先级相关参数，默认广播Stream的监听器按注册顺序触发，但该行为属于隐含实现，未在API规范中做承诺，不建议直接依赖。

可选的优雅实现方案 #

方案1：封装带优先级的广播Stream控制器 #

这种方案可以保留Stream的使用习惯，同时显式控制执行顺序，避免直接维护回调列表的生硬感。
示例代码：

class PriorityStreamController<T> {
  // 按优先级降序存储的监听器列表，数值越大优先级越高
  final List<(int priority, void Function(T) listener)> _listeners = [];
  final StreamController<T> _controller = StreamController<T>.broadcast();

  StreamSubscription<T> listen(void Function(T event) onData, {int priority = 0, Function? onError, void Function()? onDone, bool? cancelOnError}) {
    // 插入监听器时按优先级排序
    final entry = (priority, onData);
    _listeners.insert(_listeners.lastIndexWhere((e) => e.$1 >= priority) + 1, entry);
    // 返回标准StreamSubscription兼容原有取消逻辑
    return _controller.stream.listen(
      (event) => _listeners.forEach((e) => e.$2(event)),
      onError: onError,
      onDone: onDone,
      cancelOnError: cancelOnError,
    );
  }

  void add(T event) => _controller.add(event);
  // 其他需要透传的StreamController方法按需实现
}

使用时直接替换原有Stream即可：

class UserController{
  final PriorityStreamController<User> _userStream = PriorityStreamController();

  // 注册示例
  void registerListeners() {
    // B优先级更高，先执行
    _userStream.listen((event) => print("B执行"), priority: 10);
    // A优先级低，后执行
    _userStream.listen((event) => print("A执行"), priority: 5);
  }
}

方案2：分层Stream转发 #

如果优先级层级不多，可以用分层转发的方式天然保证顺序，不需要额外封装：

• 高优先级逻辑直接订阅原始Stream
• 高优先级逻辑处理完成后，将事件转发到次级Stream供低优先级逻辑订阅
  这种方式符合Stream的响应式设计理念，没有自定义逻辑侵入。

原有回调方案的修复 #

你当前维护回调列表的方案可以正常工作，但示例代码中的await写法存在问题：forEach方法不会等待异步回调执行完成，需要替换为for-in循环：

void changeUser() async {
  for(final callback in callbacks) {
    await callback();
  }
}

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