観測値を結合して以前の値と比較するRxJava

Question

異なる観測タイプを順番に組み合わせて結果を比較する最良の方法を理解しようとしています。 zipとcombineLatestを見て、私は彼らが適切だとは思わない。次のようなことをするには？

@Test 
    public void shouldInsertRecord(){ 



     BidsEntity bid = new BidsEntity(/* omitted */); 


     Observable<Integer> count1 = bidsRepository.getBid(bid.getUserId(), bid.getListingId()).count(); 

     Observable<Boolean> insert = bidsRepository.insertBid(bid); 

     Observable<Integer> count2 = bidsRepository.getBid(bid.getUserId(), bid.getListingId()).count(); 


     //run count1, run insert, run count2 in that order 
     //assert that count2 is greater than count1 

    } 

Answer 1

（別名、ブロッキング）シーケンシャルされていないがReactiveXのポイントのようなものです。

あなたの例を見てみると、入札単価が挿入されるたびに値を出す単一の観測可能性があると思います。次に、あなたはその観察可能なものを購読し、あなたが単一の観察者の情報で何をしたいのかを決める。

既に適切な設定があります。 bidsRepository.getBid(...)に、新しい入札単価が追加されるたびに発行される観測値を返し、count変数を単一のオブザーバに置き換えます。