takeWhileを毎回新しいシングルにサブスクライブします

Question

私はデータソースfun getData(page : Int) : Single<List<Data>>を持っています。

私はconditionCheck()戻りtrueまで異なるパラメータとそのソースに毎回をするたびにサブスクライブでき振る舞いを作成したいと思います。

私はこのようなものを想像：ここ

getData(page) 
    .doOnNext { page++ } 
    .doOnNext { /* manipulate data */ } 
    .takeWhile { conditionCheck() } 
    .subscribe({ 
    print "Completed" 
    }) 

Answer 1

はそれについて考えるための別の方法（擬似コードっぽい）である：

initialPage = Observable.just(1); 
futurePages = PublishSubject.create(); 

allPossiblePages = Observable.concat(initialPage, futurePages); 

allPossibleData = allPossiblePages 
    .map(page -> getData(page)) 
    .do(page -> futurePages.onNext(/* manipulate page data */)); 

dataYouWant = allPossibleData 
    .filter(data -> conditionCheck(data)) 
    .takeFirst() 
    .subscribe(/* data should be here */); 

多分これは、これを行うための最善の方法ではありませんそうだとすれば、誰かが話すだろう。私はライン.do(page -> futurePages.onNext ..)の大きなファンではないが、このような何かが動作する可能性があります。

私は一緒にここにrxjs（/デモのプロトタイプを作成するのが最も簡単）を使用して実行例を置く：https://plnkr.co/edit/uXE53ygo8REzpbMJdvsD