event_bus.dart 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960
  1. //订阅者回调签名
  2. typedef void EventCallback(arg);
  3. //ignore: slash_for_doc_comments
  4. /**
  5. 基于事件总线的事件消息通知
  6. 模板:
  7. //监听登录事件
  8. bus.on("login", (arg) {
  9. // do something
  10. });
  11. //登录页B中
  12. //登录成功后触发登录事件,页面A中订阅者会被调用
  13. bus.emit("login", userInfo);
  14. */
  15. class EventBus {
  16. //私有构造函数 //注意单例怎么写,统一的三板斧:私有构造+static变量+工厂构造函数
  17. EventBus._internal();
  18. //保存单例
  19. static final EventBus _singleton = EventBus._internal();
  20. //工厂构造函数
  21. factory EventBus()=> _singleton;
  22. //保存事件订阅者队列,key:事件名(id),value: 对应事件的订阅者队列
  23. final _emap = <Object, List<EventCallback>?>{};
  24. //添加订阅者
  25. void on(eventName, EventCallback f) {
  26. _emap[eventName] ??= <EventCallback>[];
  27. _emap[eventName]!.add(f);
  28. }
  29. //移除订阅者
  30. void off(eventName, [EventCallback? f]) {
  31. var list = _emap[eventName];
  32. if (eventName == null || list == null) return;
  33. if (f == null) {
  34. _emap[eventName] = null;
  35. } else {
  36. list.remove(f);
  37. }
  38. }
  39. //触发事件,事件触发后该事件所有订阅者会被调用
  40. void emit(eventName, [arg]) {
  41. var list = _emap[eventName];
  42. if (list == null) return;
  43. int len = list.length - 1;
  44. //反向遍历,防止订阅者在回调中移除自身带来的下标错位
  45. for (var i = len; i > -1; --i) {
  46. list[i](arg);
  47. }
  48. }
  49. }
  50. //定义一个top-level(全局)变量,页面引入该文件后可以直接使用bus
  51. var bus = EventBus();