RxJava: şartlı gözlenebilir bir RxJava I operatörlerin zinciri var zincirini

Question

kırmadan gözlemlenebilir için Operatörleri nasıl uygulanır. Ben "zincirini kesmeden" bir boolean değerine bağlı olarak iki operatör birini uygulayabilecektir istiyorum.

ben Rx (Java) nispeten yeni ve büyük olasılıkla geçici değişken tanıştırmak benim şimdiki yaklaşımından daha bunu yapmanın daha deyimsel ve okunabilir yolu var gibi hissediyorum.

Burada aksi toList() ile sınırsız boyutta tek parti yayan bir parti boyutu saha boş olmayan ise bir gözlemlenebilir öğeleri tamponlama somut örnek:

Observable<Item> source = Observable.from(newItems); 
Observable<List<Item>> batchedSource = batchSize == null ? 
       source.toList() : 
       source.buffer(batchSize); 
return batchedSource.flatMap(...).map(...) 

bu mümkün gibi bir şey var mı? (Java çünkü sözde lambda'lar):

Observable.from(newItems) 
    .applyIf(batchSize == null, 
      { o.toList() }, 
      { o.buffer(batchSize) }) 
    .flatMap(...).map(...) 

Answer 1

You-dizisine kalmak compose(Func1) kullanabilirsiniz ama yapacak özel davranış

source 
.compose(o -> condition ? o.map(v -> v + 1) : o.map(v -> v * v)) 
.filter(...) 
.subscribe(...)