LocalRxBus.java

public class LocalRxBus {
    private static LocalRxBus instance;

    private PublishSubject<Object> subject = PublishSubject.create();

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

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

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