RxBus

RxBus.java

public class RxBus {

    private static RxBus sInstance;

    private final Relay<Object> mBus = PublishRelay.create().toSerialized();

    public static RxBus getInstance() {
        if (sInstance == null){
            sInstance = new RxBus();
        }
        return sInstance;
    }

    public void publish(@NonNull Object object){
        mBus.accept(object);
    }

    public <T> Observable<T> subscribe(@NonNull Class<T> type) {
        return mBus.ofType(type);
    }
}