Rxbus 关键源码

       /** 提供了一个新的事件,根据code进行分发     * @param code 事件code
     * @param o
     */
    public void post(int code, Object o){
        _bus.onNext(new RxBusBaseMessage(code,o));

    }

/**
     * 根据传递的code和 eventType 类型返回特定类型(eventType)的 被观察者
     * 对于注册了code为0，class为voidMessage的观察者，那么就接收不到code为0之外的voidMessage。
     * @param code 事件code
     * @param eventType 事件类型
     * @param <T>
     * @return
     */
    public <T> Observable<T> toObservable(final int code, final Class<T> eventType) {
        return _bus.ofType(RxBusBaseMessage.class)
                .filter(new Func1<RxBusBaseMessage,Boolean>() {
                    @Override
                    public Boolean call(RxBusBaseMessage o) {
                        //过滤code和eventType都相同的事件
                        return o.getCode() == code && eventType.isInstance(o.getObject());
                    }
                }).map(new Func1<RxBusBaseMessage,Object>() {
                    @Override
                    public Object call(RxBusBaseMessage o) {
                        return o.getObject();
                    }
                }).cast(eventType);
    }

 使用

初始化被观察者 接受消息并处理

 /**
     * 在任何界面出发操作 这里响应
     */
    @Override
    public void initRxBus() {
        Subscription subscribe = RxBus.getDefault().toObservable(RxCodeConstants.SHOW_TOAST, String.class)
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String s) {
                        showToast("首页收到消息---："+s);

                    }
                });
        addSubscription(subscribe);
    }

在任何地方发送消息

RxBus.getDefault().post(RxCodeConstants.SHOW_TOAST,"发送消息可在任何地方");