RxJava事件总线

Question

使用的第一个版本RxJava和RxAndroid我有以下class为EventBus:

public class RxBus {
private static RxBus instance;
private PublishSubject<Object> subject = PublishSubject.create();

public static RxBus instanceOf() {
    if (instance == null) {
        instance = new RxBus();
    }
    return instance;
}

public void setMessage(Object object) {
    subject.onNext(object);
}

public Observable<Object> getEvents() {
    return subject;
}
}

instanceOf在任何类中获取实例 ,我使用setMessage方法发出消息并使用代码来获取发出的消息:

  bus.getEvents().subscribe(new Action1<Object>() {
        @Override
        public void call(Object o) {
            if (o instanceof String) {
                //TODO
            }
        }
    });

Action1来自rx.functions包裹.尝试迁移使用RxJava 2我无法导入它.

请告诉我,什么是用最短的方式RxJava 2为EventBus

Answer 1

在RxJava2中,Action1已重命名为Consumer.

其余的操作接口根据Java 8功能类型命名.在没有参数Action0被替换io.reactivex.functions.Action为运营商和java.lang.Runnable该Scheduler方法.Action1已被重命名为Consumer并被Action2称为BiConsumer.ActionN由Consumer<Object[]>类型声明替换.

请参阅2.0中的不同之处