事件总线-RxBus-源码学习过程

直接上代码

public class RxBus {
    private static volatile RxBus defaultInstance;

    private final Subject<Object, Object> bus;
    public RxBus() {
      bus = new SerializedSubject<>(PublishSubject.create());
    }
    public static RxBus getDefault() {
        if (defaultInstance == null) {
            synchronized (RxBus.class) {
                if (defaultInstance == null) {
                    defaultInstance = new RxBus();
                }
            }
        }
        return defaultInstance ;
    }
    public void post (Object o) {
        bus.onNext(o);
    }
    public <T> Observable<T> toObservable (Class<T> eventType) {
        return bus.ofType(eventType);
    }
}```

使用过Rxjava的一看就懂了，没使用过的也没有必要特意去学习这个。看项目有没有使用吧。