RxJavaEventBusExample

RxJavaEventBus

public class EventBus {

    private final Subject<Boolean, Boolean> eventBus = new SerializedSubject<>(PublishSubject.<Boolean>create());

    private EventBus() {
    }

    private static class SingleTonHelper {
        private static final EventBus INSTANCE = new EventBus();
    }

    public static EventBus getInstance() {
        return SingleTonHelper.INSTANCE;
    }

    public void send(boolean isBoolean) {
        eventBus.onNext(isBoolean);
    }

    public void onError(Throwable throwable) {
        eventBus.onError(throwable);
    }

    public void onCompleted() {
        eventBus.onCompleted();
    }

    public Observable<Boolean> toObservable() {
        return eventBus;
    }
}