event_bus.dart 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. //订阅者回调签名
  2. typedef void EventCallback(arg);
  3. class EventBus {
  4. //私有构造函数
  5. EventBus._internal();
  6. //保存单例
  7. static EventBus _singleton = EventBus._internal();
  8. //工厂构造函数
  9. factory EventBus() => _singleton;
  10. //保存事件订阅者队列,key:事件名(id),value: 对应事件的订阅者队列
  11. var _emap = Map<Object, List<EventCallback>?>();
  12. //添加订阅者
  13. void on(eventName, EventCallback f) {
  14. if (eventName == null) return;
  15. _emap[eventName] ??= [];
  16. _emap[eventName]!.add(f);
  17. }
  18. //移除订阅者
  19. void off(eventName, [EventCallback? f]) {
  20. var list = _emap[eventName];
  21. if (eventName == null || list == null) return;
  22. if (f == null) {
  23. _emap[eventName] = null;
  24. } else {
  25. list.remove(f);
  26. }
  27. }
  28. //触发事件,事件触发后该事件所有订阅者会被调用
  29. void emit(eventName, [arg]) {
  30. var list = _emap[eventName];
  31. if (list == null) return;
  32. int len = list.length - 1;
  33. //反向遍历,防止在订阅者在回调中移除自身带来的下标错位
  34. for (var i = len; i > -1; --i) {
  35. list[i](arg);
  36. }
  37. }
  38. }
  39. //定义一个top-level变量,页面引入该文件后可以直接使用bus
  40. var eventBus = EventBus();