Vidaları işlemek için etkili bir yol RxJava

Question

Projemde farklı iş parçacıklarındaki nesneleri işlemem gerekiyor.

apiService.getObjects(token) // Retrofit 
       .compose(bindToLifecycle()) 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .doOnNext(o -> { 
        // process in Main Thread 
       }) 
       .map(Observable::just) // create new one, to change thread for it 
       .observeOn(Schedulers.io()) 
       .subscribe(o -> { 
        // process in the background thread 
       }); 

Ama RxJava içinde farklı evrelerde tek yanıtı işlemek için güzel ve verimli bir şekilde çok daha fazla olduğunu düşünüyorum: streamin davranışını işlemek için onların observeOn() bu şekilde değiştirmek için yeni gözlenebilirleri oluşturun. Onu google denedim, ama hiçbir şey bulamadım.

sayesinde Rx ise
Anton

Answer 1

, genellikle (dere üzerinde abone alırsa sadece yürütülecektir) 'do' bloklarda yan etkilerinden kaçınmak için tavsiye ve kod abone tercih ediyor. Senin durumunda

Eğer cache() veya publish()...connect(), kaldıraç ör:

yerine cache() ait publish() ile

query = apiService.getObjects(token) 
      .compose(bindToLifecycle()) 
      .subscribeOn(Schedulers.io()) 
      .cache(); 

query.observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(o -> { 
       // process in Main Thread 
      }) 
query.observeOn(Schedulers.io()) 
      .subscribe(o -> { 
       // process in the background thread 
      }); 

, kod aynıdır ancak sorgu ateş ederken (akışı bağlayan sizi karar verebilir 2 aboneliği kabloladıktan sonra query.connect() numaralı telefonu arayın.

Abonelik işiniz arka plan hesaplamasıysa, Schedulers.computation(), Schedulers.io() üzerinden tercih edilebilir. kodunuzu 'observeOn' ifadeleri sadece daha aşağı akışı etkileyebilir olarak, map(Observable::just) hattı olmadan da gayet iyi çalışır AFAICT

Not (değil önceki 'do' ifadeleri)