rx-java

0熱度

1回答

我想解決這個問題，我從下面的代碼，其中，類型推斷是沒有做我想要的得到一個類型不匹配的編譯器錯誤。我有一個密封類和rxjava流： sealed class Result { data class Success(val logs: List<Log>) : Result() data class Failure(val throwable: Throwable) : Resul

-1熱度

1回答

什麼是一個SwipeRefreshLayout

使用RxBinding清爽的idomatic方式我努力理解如何正確使用RxBinding，如果我要當一個用戶刷下來一個SwipeRefreshLayout調用網絡請求，我希望說些什麼像 RxSwipeRefreshLayout.refreshes(swipeContainer) .flatMap { networkRequest() } .subscribeBy(

0熱度

1回答

春天5反應堆 - 發射項目每1秒

我試圖發出值每秒爲 Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1)) ，但它是在一次與啓動1秒的延遲發射的一切。我怎樣才能引入每個元素髮射的延遲？

1熱度

1回答

Observable仍然在UI線程上運行

我遇到了在新線程上運行RxJava observables的問題。我試圖在Scheduler.io()上運行壓縮的DB查詢，但它無論如何都會阻塞UI線程。不知道爲什麼。代碼爲DB： public Observable<List<T>> searchModelsInView(View view, final Collection<String> searchTerms, KeyMatc

1熱度

2回答

在RxJava上使用Android上的清潔MVP：如何讓演示者在使用UI線程的同時觀察任何Android知識？

在實施上，建議治療Android框架作爲一個插件，不會泄露任何Android意識到依賴到演示層MVP模式Android的「乾淨」架構的努力。使用rxjava，如果我有被設計爲「推」的數據到視圖層演示者本人可能希望有這樣的邏輯： public interface SearchPresenter { interface ViewLayer { void updateResults

1熱度

1回答

我是否應該使用BehaviorSubject從變量創建Observable，如果我只希望變量在變化時發出自己的變量？

（首先，雖然我認爲這是與一般Rx編程的問題，而是因爲我開發Android和使用RxJava，下面的問題將在Android和RxJava方面要求。）我是新到RxJava，因此希望首先以一些簡單的方式實現它。方案我有一個表格，我想啓用按鈕只有在表單中的所有必要的字段已經填寫。我已經成功地實現這個功能，對所有 EditText輸入。現在，我的表單也有一個圖像選擇。因此，我有一個Bitmap變

1熱度

1回答

如何監聽單獨線程中的HashMap值更改使其變得流暢？

我有一個項目的地圖我要聽的變化，並做出一些行動，我想這樣做在單獨的線程，但地圖改變，但我能聽它的變化 val removedItemList: HashMap<Int,Item> = HashMap() Flowable.fromArray(removedShoppingList.values).subscribeOn(Schedulers.io()) .observeOn(And

0熱度

1回答

在RxJava中超時

我是RxJava的新手，我需要以異步方式使用Observable功能。我還需要使用超時：在我的例子中，我希望每個進程在1秒或更短的時間內結束。這裏是我現在做： public static void hello(String name) throws IOException { Observable<String> obs2 = Observable.just(name).timeout(10

0熱度

1回答

RxJava 2無限可觀的力量完整鏈條

我有可觀察的鏈條，它在頂部有無限可觀察點，在它之後有無限可觀察點。像這樣： repo.infinitGetItems() .switchMap(items -> Observable .just(items) .flatMap(items -> repo.nonInfinitObs(items))); 我想要的是當repo.nonInfi

2熱度

1回答

在Rx Observable事務中使用Realm調用時，如何防止Realm Threading問題？

這是視圖模型，其中的Rx交易被稱爲 RealmHelperRepo是HelperRepo接口 @PerActivity public class RoleSelectionViewModel extends BaseViewModel<RoleSelectionMvvm.View> implements RoleSelectionMvvm.ViewModel { private Di