rx-java

0ısı

1cevap

RxScala, birden fazla Gözlemci ile abone olmak için sadece bir tane yayınlayın.

Çoklu Observer'u kullanmayı denedim , bir döngü içinde onNext meydana geldi. Her bir Gözlemci için işe yaramaz. Sadece ikinci bir abone alamaz Neden ilk Observer first observer - hi~ first observer -

4ısı

2cevap

rxjava interval() bazı olaylardan sonra sıfırlama süresi

RxJava ile bir Android uygulaması yapıyorum, sayfanın birinde, bir düğmeye bastığımda, basıldığında, sayfa yenilenecek. Ayrıca, kullanıcı o andaki düğmeye basmamışsa, her 10 saniyede bir otomatik yeni

3ısı

1cevap

RxJava - flatmap vs concatMap - neden abonelikte sipariş veriyorsunuz?

this thread conCatMap ve düzmap'ye göre, yalnızca öğelerin gönderildiği sıraya göre farklılık gösterir. Bu yüzden bir test yaptım ve basit bir tamsayı akışı yarattım ve hangi sırada yayılacağını görme

3ısı

1cevap

RxJava, varsa ilk madde

RxJava kullanarak bir listeden ilk öğeyi almaya çalışıyorum. Ancak, öğe mevcut değilse bir hata atmak istemiyorum. Bunun yerine, varsayılan öğeyi sağlayarak kendimi halledebilmek istiyorum. Aşağıda ol

1ısı

1cevap

Retrofit + RxJava

kullanarak istekler arasındaki veri aktarımı projemde Retrofit 2.0 + RxJava kullanmaya karar verdim. Asıl sorun, nasıl olması gerektiğini tam olarak anlamadığım. İlk önce tüm istekler benim sunucu API

0ısı

1cevap

Gözlemleri, çalışma zamanına kadar izledikten sonra paralel olarak çalıştırınız.

Paralel olarak birkaç gözlenebilirliği çalıştırmak istediğimde ve hangisinin olduğunu bildiğimde combineLatest() kullanın. Birden çok gözlemcinin paralel olarak nasıl çalışılacağına, ancak çalışma zam

0ısı

2cevap

flux.take (x) veya flux.all (..) tüm emisyonları beklemez

Iterable 8 öğesinden() oluşturulan bir flux var. Her bir akı emisyonu için, bir senkronize olmayan bir yöntemi çağırmak istiyorum. Ben çalışmak ve sonunda ben fluxflux<CompletableFuture<Boolean>> dönü

11ısı

1cevap

rxjava android abonesi onNext() 2 değer almak mümkün mü?

Ben profileListener.onProfileSet(userProfile,extensions); olarak yönteminde profileListener.onProfileSet(userProfile); yılında ArrayList geçmesi gerekiyor bu Observable.zip(observable, extObs, new Fun

9ısı

2cevap

Gözlemlenebilir bir istisna ile Observable.fromCallable() nasıl kullanılır?

Observable.fromCallable(), tek bir işlevi Gözlemlenebilir hale getirmek için harikadır. Ancak, işlevin atlatabileceği kontrol edilen istisnaları nasıl ele alırsınız? Gördüğüm örneklerin çoğu, lambdas

0ısı

2cevap

RxJava ve RxAndroid - İkisine de mi ihtiyacım var?

Benzer bir soru here var, ancak bu soruyu gerçekten yanıtlamıyor. Android uygulamasında RxJava ve RxAndroid kullanıyorum ve şimdi proje çalışıyor. Sonra RxJava'yı kaldırdım ve yalnızca RxAndroid'i bır