Dart事件总线

作者: brycegao | 来源:发表于2019-01-29 11:39 被阅读1次

因为Flutter不支持反射, 所以无法实现像EventBus那样通过注解添加观察者并反射执行对应函数。 在Flutter开发中, 可以通过单例模式和观察者模式实现事件总线。

暂时不支持黏性事件, 后续有需要的话再完善, 把EventBus.java翻译成Dart就成了。

DashPad不支持json,示例代码就没做json序列化。但事件总线可以参考EventBus那样传递JSON。

///import 'package:json_annotation/json_annotation.dart'
  
void main() {
  var eventbus = new DartEventBus();
  
  eventbus.register("login", (arg){
    print("收到事件");
    if (arg is LogInInfo) {
      print(arg.name);
    }
  });
  
  //第二个观察者
  eventbus.register("login",(arg){
    print("收到事件2222 ");
  });
  
  var data = new LogInInfo("dddd", "张三");
 
  eventbus.postEvent("login", data);
}
 
///@JsonSerializable()
class LogInInfo {
  String token;
  String name;
  
  LogInInfo(this.token, this.name);
}
 
typedef void DartEventCallback(arg);
 
class DartEventBus {
  DartEventBus._internal() {
 
  }
  static DartEventBus get instance => getInstance();
  factory DartEventBus() => getInstance();
  static DartEventBus _instance;
 
  static DartEventBus getInstance() {
    if (_instance == null) {
      _instance = new DartEventBus._internal();
    }
    return _instance;
  }
 
  /// Object是事件标识, 观察者可以有多个所以要用数组List保存
  var _eventMap = new Map<Object, List<DartEventCallback>>();
 
  ///注册观察者
  ///[name]是观察者标识,一般是字符串
  ///[callback]回调
  bool register(name, DartEventCallback callback) {
    if (name == null || callback == null) {
      return false;
    }
 
    ///三目操作符,如果为空则实例化列表,非空时无操作
    _eventMap[name] ??= new List<DartEventCallback>();
    if (_eventMap[name].contains(callback)) {
      print(name + " had already register");
    } else {
      _eventMap[name].add(callback);
    }
    return true;
  }
 
  ///移除多个观察者
  ///[name]是观察者标识,一般是字符串
  ///[callback] 回调数组,根据标识删除若干个回调
  bool unregister(name, [DartEventCallback callback]) {
    var list = _eventMap[name];
    if (name == null || list == null || list.length == 0) {
      return false;
    }
 
    if (callback == null) {
      _eventMap[name] = null;
    } else {
      ///批量移除
      list.remove(callback);
    }
    return true;
  }
 
  ///触发事件
  void postEvent(name, arg) {
    if (name == null) {
      return;
    }
    var list = _eventMap[name];
    if (list == null || list.length == 0) {
      return;
    }
 
    for (var i = list.length - 1; i >= 0; i--) {
      list[i](arg);
    }
  }
}

上述代码可以在DartPad上验证, https://dartpad.dartlang.org
语法参考:https://www.jianshu.com/p/64a6ed7581aa

相关文章

  • Dart事件总线

    因为Flutter不支持反射, 所以无法实现像EventBus那样通过注解添加观察者并反射执行对应函数。 在Flu...

  • RxJava实现事件总线(RxBus)学习笔记

    目录事件总线的介绍利用RxJava实现事件总线(Rxbus)Rxbus的使用 事件总线的介绍 1. 什么是事件总线...

  • 事件总线知多少(1)

    源码路径:Github-EventBus事件总线知多少(1)事件总线知多少(2) 1. 引言 事件总线这个概念对你...

  • 事件总线知多少(2)

    源码路径:Github-EventBus事件总线知多少(1)事件总线知多少(2) 1.引言 之前的一篇文章事件总线...

  • 使用JavaScript手写一个事件总线功能

    事件总线 事件总线主要是实现一些任意的或非父子关系的组件之间的数据通信 实现一个事件总线功能需要: 事件派发 $...

  • 走马观花 - EventBus

    EventBus是Android的中央发布/订阅事件系统。 事件被post到总线,总线将事件传递给具有事件类型的匹...

  • [大白装逼]YEventBus事件总线的实现

    Y事件总线:基于java的Observe和Observable实现的事件总线github地址:https://gi...

  • 事件总线

    Android应用开发中,经常会涉及Activity,Fragment,Service等不同组件或者模块之间的消息...

  • 事件总线

    EventBus 3.0进阶:源码及其设计模式 完全解析 EvenBus3.0用法介绍 Eventbus Squa...

  • 事件总线

    事件总线,提供了一个,解耦合,和异步的能力

网友评论

    本文标题:Dart事件总线

    本文链接:https://www.haomeiwen.com/subject/nixxsqtx.html