Polling at Dynamic Rate with RxJava

RxDynamicPoll.java

BehaviorSubject<Integer> timerSubject = BehaviorSubject.create(1);

timerSubject
    .switchMap(interval -> Observable.timer(interval, TimeUnit.SECONDS, Schedulers.newThread()))
    .flatMap(i -> Observable.just(randomInt()))
    .doOnNext(timerSubject::onNext)
    .subscribe(System.out::println);