Androidどのように時間間隔を変化させてObservableを作成する

Question

x秒ごとに放出する観測可能物を作成したいと思います。このxはある条件によって変わる可能性があります。

今私は私に4秒間イベントを送信するものがあります。

Observable.interval(4, TimeUnit.SECONDS) 
    .takeUntil(new Func1<Long, Boolean>() { 
     @Override public Boolean call(Long aLong) { 
     return !showNextText; 
     } 
    }) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribeOn(Schedulers.newThread()) 
    .subscribe(new Action1<Object>() { 
     @Override public void call(Object o) { 


     } 
    }, new Action1<Throwable>() { 
     @Override public void call(Throwable throwable) { 

     } 
    }, new Action0() { 
     @Override public void call() { 
     } 
    }); 

Answer 1

concatMapおよびtimerを使用してください。私は強くOPは、定数の一連の時間の可変量を望んでいた、といないと思われる

Observable.just(1, 2, 3) 
    .concatMap(n -> Observable.timer(n, TimeUnit.SECONDS)) 
    .doOnNext(System.out::println) 
    .toBlocking().subscribe();