RxJava- Nasıl bir flatmap() geri yüklemek için()

Question

Belki de operatörlerin basit bir kombinasyonuna bakıyorum (ya da RxJava'nın tamamen iptal etme davranışı). Ancak, bir RxJava-JDBC sorgusuna ait düzlemleri gösteren, sıcak gözlemlenebilir bir selectedItem var. o DAİMA sadece en son sorguyu yürütmek (ve herhangi bir önceki iptal) böylece

@Test 
public void testFlatMapBackPressure() { 
    Database db = null; //assign db 

    BehaviorSubject<Integer> selectedItem = BehaviorSubject.create(); 

    //can I backpressure the queries so only the latest one is running, and any previous is cancelled? 
    Observable<List<Integer>> currentValues = selectedItem.flatMap(i -> db.select("SELECT VALUE FROM MY_TABLE WHERE ID =?") 
      .parameter(i) 
      .getAs(Integer.class) 
      .toList()); 
} 

nasıl flatMap() operatörünü karşı basıncı olabilir. Ben biraz böyle bir şey yapmak için bir backpressured flatMap operatörü, "X" önceki sorguda

bunu yapmanın bir yolu var mı bir iptal gösterir nerede istiyorsun? Ya da zaten başarılabilir ve ben sadece görmüyorum?

Answer 1

flatMap() yerine switchMap()'a ihtiyacınız olduğu gibi geliyor.

bir gözlemlenebilir döndüren gözlemlenebilir kaynak tarafından yayılan her öğenin tedarik bir işlevi uygulayan ve sonra en son bu gözlenebilirlerin yayılan yaydığı öğeleri yayan yeni gözlemlenebilir döndürür.