RxBusImpl.java 文件源码

@Override
public void register(Object object) {
    if (object == null) {
        throw new NullPointerException("Object to register must not be null.");
    }
    CompositeSubscription compositeSubscription = new CompositeSubscription();
    EventComposite subscriberMethods = EventFind.findAnnotatedSubscriberMethods(object, compositeSubscription);
    mEventCompositeMap.put(object, subscriberMethods);

    if (!STICKY_EVENT_MAP.isEmpty()) {
        subscriberMethods.subscriberSticky(STICKY_EVENT_MAP);
    }
}