rx-java

24ısı

1cevap

arasındaki fark Hangi durumlarda doOnNext kullanmalıyım ve hangi durumlarda doOnEach? .doOnEach(new Action1<Notification<? super MessageProfile>>() { @Override public void call(Notific

14ısı

2cevap

RxJava tekli arka plan iş parçacığı zamanlayıcısı

RxJava'ya oldukça yeniyim, bu muhtemelen aptalca bir soru. Senaryonumu tarif edeceğim. Bazı resimleri güncelleştiren UI iş parçacığı üzerinde bazı kodlar var ama bu görüntüler çok önemli değil ve üret

21ısı

2cevap

Split Rx Birden çok akışa gözlenebilir ve tek tek işlenebilir

İşte, neyi başarmaya çalıştığımı gösteren bir resim. --abca - bbb - bir bölünmüş içine -a ----- bir ------- a -> bir akış - --- b ------ bbb --- -> b akışı ------ c ---------- -> O; c a.subscribe() b

6ısı

2cevap

Gözlemlenebilirler doOnError doğru konum

Observers için yeni bir tür ve hala bunları çözmeye çalışıyorum. observableKafka.getRealTimeEvents() .filter(this::isTrackedAccount) .filter(e -> LedgerMapper.isDepositOrClosedTrade((Trans

7ısı

3cevap

kaçınmak MissingBackpressureException istisnalar

, ürün sürekli olarak iç kuyruklar ilave edilecektir. ReactiveX (RXJava) olarak , bunların geri basınç oluşturmak başladığında istisnalar atarak farklı bir duruş almış görünür. Bu, onBackpressureBuffe

12ısı

1cevap

Android'de RxJava, OkHttp ve Okio ile indirme ilerlemesini

Bizim app Bu kod ile bir görüntü dosyası indirmek. UI'de indirme ilerlemesini (indirilmiş bayt yüzdesi) göstermem gerekiyor. Bu kodda indirme ilerlemesini nasıl alabilirim? Çözüm aradım ama yine de ke

5ısı

3cevap

RxJava ve Güçlendirme - Sunucu yanıtına bağlı olarak özel istisnaları yükseltme

Retrofit'in sunucu yanıtına bağlı olarak özel istisnalar geliştirmesini istiyorum. Aşağıdaki yapıda Örneğin: { "code":0, "message":"OK", "data":{....} } code 0'dan dışında bir Nasıl Sonradan mon

5ısı

1cevap

RxJava retrySonra yayımı yeniden gönderirken

İletişim için bir Android uygulamasında RxJava ile Retrofit kullanıyorum ve yanıtı tamam yanıt veren HTTP yanıtından (status 200 code) çözümlemede hatayla uğraşmak zorundayım. Ayrıca, yeniden deneme y

26ısı

2cevap

Zinciri iki retrofit gözle görülür zincirleme w/RxJava

2 ağ çağrısını birbiri ardına yürütmek istiyorum. Her iki ağ çağrısı da Gözlenebilir. İkinci çağrı, ilk aramanın başarılı sonucundan veri kullanır, ikinci aramanın başarılı sonucundaki yöntemde, numar

13ısı

2cevap

Projede eksik olan Avarası bulun

Bir projede eksik bir onError() bulmaya çalışıyorum. Bu, bir abonelik throwables işlemez, çünkü bu alt yazıyı bulmak ve onError yöntemini eklemek istiyorum çünkü uygulama çöker demektir. Maalesef Stac