2016-12-03 26 views

cevap

28

the documentation belirtildiği gibi:

RxJava 0.x içinde geri basınç sokulması ile ilgili küçük bir pişman yerine ayrı bir taban reaktif sınıf olan, gözlemlenebilir kendisi sonradan olmasıdır. Geri tepme ile ilgili temel sorun, UI olayları gibi birçok sıcak kaynağının makul bir şekilde geri dönüştürülemez ve beklenmedik nedenlere neden olabilir MissingBackpressureException (yani yeni başlayanlar, onları beklemez).

Biz io.reactivex.Observable-olmayan backpressured ve yeni io.reactivex.Flowable olmak backpressure özellikli taban reaktif sınıf sahip olarak 2.x bu durumu düzeltmek için deneyin.

Kullanım Observable zaman (< 1000) ve/veya orada yapımcı overflooding tüketicilerin riski olduğunu ve bu nedenle neden OOM üzerinde nispeten az öğeler var.

Flowable'u göreceli olarak büyük miktarda ürüne sahip olduğunuzda kullanın ve kaynakların tükenmesini ve/veya tıkanıklıklarını önlemek için Producer'un nasıl davranacağını dikkatle denetlemeniz gerekir. Karşı basınç bu kadar hızlı tüketim yayılan ancak tüketilmemiş öğelerin varlığı giden akışı takip edemez öğeleri yayar hangi bir gözlemlenebilir var


. Gözlemciler tarafından tüketilen, ancak tüketilmeyen tüketiciler tarafından tüketilmeyen tükenmeyen malzemeler nasıl yönetilir ve kontrol edilir, geri tepme stratejisinin ne ile uğraştığıdır.

Ref link

+2

Yine de ortak bir arabirimi desteklemeleri gerektiğini düşünürdüm veya Akışkan Gözlemlenebilir'i genişletmeli, bu şekilde birleştirilebilsin ve –