rx-java

11ısı

1cevap

rx oluşturulduktan sonra eleman ekleme Gözlemlenebilir

Gözlemlenebilir'in oluşturulmasından sonra eleman eklemek istediğimde senaryoyu nasıl uygulayabilirim, hiç yapılmaz mı? Gözlemci modelinde sadece olayı falan ateşlerdim. Bazı fikirlerin var mı? import

5ısı

1cevap

RxJava, yeni aboneler için son değerle paylaş

BehaviourSubject'un bir çok işlevi olan bir dönüşüm sonucu bir Observable oluşturdum. Şimdi, Observable'un değerlerini paylaşmak istiyorum, böylece her yeni abone için fonksiyon zinciri yeniden çalışt

6ısı

1cevap

RxJava Android - Düz dişlilerle ilgili, yükleme-önbellekli gösterim verileri

RxJava'yı ve Android'e uygulanabilirliğini araştırıyorum ve aşağıdaki ASCII'de gösterildiği gibi basit bir önbellek gösterimli kullanım durumu uygulamaya çalışıyorum grafik: bir arka plan iş parçacığı

15ısı

1cevap

RxJava zincirleme gözlenebilirler ve hata işleme (özel istisna yayılımı)

flatMap ile zincirlenmiş 5 Observable s var. İlk dört Observable s'nin bir Exception üretmesi durumunda, farklı bir Exception türünü beşte birine yaymak istiyorum. Nasıl elde edilir? Teşekkürler. P.S.

53ısı

2cevap

RxJava Paralel İlerleme Gözlemleri

RxJava'da paralel eşzamansız çağrıları uygulama konusunda yardıma ihtiyacım var. FIRST çağrısı, görüntülenecek olan ürünlerin (Çini) bir listesini (daha doğrusu arar) getirdiği basit bir kullanım duru

6ısı

1cevap

Birleşik akışları yalnızca akışlardan biri

değiştiğinde yayılır Sık akış değerlerine sahip bir akımım var ve diğeri daha yavaş olanlarla. Onları birleştirmek istiyorum, ancak daha yavaş olanı yaydığında sadece bir değer yayar. Yani combineLate

8ısı

1cevap

rxjava ve clojure asynchrony gizemi: gelecek vaatler ve aracılar, benim

Bu notun uzunluğu için şimdiden özür dilerim. Daha kısa sürede yapmak için çok zaman harcadım ve bu onu alabildiğim kadar küçüktü. Bir gizem var ve yardımlarınız için minnettar olacağım. Bu gizem, çev

5ısı

1cevap

RxAndroid: bindActivity ne zaman kullanılır ve neden?

Aşağıdaki etkinlik gibi durumlarda AndroidObservable.bindActivity(...) kullanmak gerçekten gerekli midir? Yine de manuel olarak onDestroy'dan yine de aboneliğinizi iptal etmeniz gerekiyor. this blog m

9ısı

1cevap

Güçlendirme/Rxjava ve oturum tabanlı hizmetler

Oturum tabanlı hizmetler uygulamıyorum. Tüm isteklerin bir cookie session param ile abone olması gerekir, bu da sırayla ayrı dinlenme api ile alınır. Dolayısıyla temel iş akışı, oturum çerezini almak

9ısı

1cevap

Nesneyi getirmek için RxJava'yı kullanma, içeren bir listeyi dönüştürme ve listeyi kullanma

Çözmeyi denediğim yüksek düzey sorun, FooContainer (Gözlenebilir) öğesinde bulunan Foo nesnelerinin bir listesini FooBar nesnelerinin listesine dönüştürmektir. RxJava. Benim (karışık) girişimi: fooCon