RxBus实现

1 添加Gradle:

//RxAndroid
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'io.reactivex.rxjava2:rxjava:2.0.4'

2 添加RxBus类:

public class RxBus {
private static volatile RxBus mInstance;
private final Subject<Object> subject = PublishSubject.create().toSerialized();
private Disposable dispoable;


private RxBus() {
}

public static RxBus getInstance() {
    if (mInstance == null) {
        synchronized (RxBus.class) {
            if (mInstance == null) {
                mInstance = new RxBus();
            }
        }
    }
    return mInstance;
}


/**
 * 发送事件
 * @param object
 */
public void send(Object object) {
    subject.onNext(object);
}


/**
 * @param classType
 * @param <T>
 * @return
 */
public <T> Observable<T> toObservale(Class<T> classType) {
    return subject.ofType(classType);
}


/**
 * 订阅
 * @param bean
 * @param consumer
 */
public void subscribe(Class bean, Consumer consumer) {
    dispoable = toObservale(bean).subscribe(consumer);
}

/**
 * 取消订阅
 */
public void unSubcribe(){
    if (dispoable != null && dispoable.isDisposed()){
        dispoable.dispose();
    }

}

}

3 添加监听

 RxBus.getInstance().subscribe(String.class, new Consumer<String>() {
        @Override
        public void accept(String path) throws Exception {
                        
        }
 });

4 发送监听事件：

 RxBus.getInstance().send("发送事件");

5 在退出Activity(Fragment)时,取消监听:

 RxBus.getInstance().unSubcribe();