RxJava作为Android项目中的事件总线-从总线中删除事件

只要你不打算允许 events 成为 null ,我认为这很容易实现。

正如你所说,你可以使用 BehaviorSubject 传播 sticky 事件,以及何时需要 removeStickyEvent 来自 bus ,您可以发出 无效的 对象(以“刷新” subject ).

类似这样的东西(从我的头顶上看-没有测试,没有泛型,只是一个简单的 Object -基于事件的示例):

public class RxEventBus {

    PublishSubject<Object> eventsSubject = PublishSubject.create();
    BehaviorSubject<Object> stickyEventsSubject = BehaviorSubject.create();

    public RxEventBus() {
    }

    public Observable<Object> asObservable() {
        return eventsSubject;
    }

    public Observable<Object> asStickyObservable() {
        return stickyEventsSubject.filter(new Func1<Object, Boolean>() {
            @Override
            public Boolean call(Object o) {
                return o != null;
            }
        });
    }

    public void postEvent(@NonNull Object event) {
        eventsSubject.onNext(event);
    }

    public void postStickyEvent(@NonNull Object stickyEvent) {
        stickyEventsSubject.onNext(stickyEvent);
    }

    public void removeStickyEvent(){
        stickyEventsSubject.onNext(null);
    }
}