rx-java

1熱度

1回答

0熱度

3回答

Rxjava使用郵編操作

我使用壓縮合並2可觀察與完美下面的代碼 Observable<boolean> one = someMethod(); Observable<String> two = someMethod2(), Observable.zip(one, two, new Func2<boolean, String, newPojo>() { @Override public MyR

0熱度

1回答

在Android中使用RxJava和MVVM模式處理錯誤

我正在開發應用程序，其中我想使用MVVM模式。目前，來自xml的所有事件都由將它們傳遞到ViewModel旁邊的活動來處理。例如。用戶點擊登錄按鈕，事件由活動處理;現在這個活動調用視圖模型的方法，在這個方法裏面我調用了RxFirebase（Firebase上的Rx包裝），它返回Observable，訂閱它們並返回它;鑑於我再次訂閱這個可觀察的UI做更新。下面介紹了這種情況。我的問題是如果這種方法

0熱度

1回答

RxJava 2：在一定時間後發出收集的項目列表

我有一個Observable，它正在偵聽數據庫並在添加到db時發出項目。當我訂閱這個可觀察的數據庫時，它已經將已經存儲的數據項一個接一個地發送出去了。我的問題是我可以創建observable，它將收集以某個時間間隔（例如100毫秒）發送到列表中的項目，併發出（或返回某個函數中的doOnNext）整個列表和單獨項目間隔？提前致謝！

0熱度

1回答

RxJava - 結合2個呼叫

我有2個觀測量，其中要求2 WS 獲取汽車列表（在這一點上，從這個列表中的每個車沒有他的主人）獲取車的車主所以首先我得到汽車列表。一切都好。但是我會爲每輛車獲得車主，並將其設置在Car實體中，如car.setOwner(owner)，併發送包含車主在內的最終汽車列表。 Api.getCars() .subscribe(new Action1<List<Car>>() { @Over

3熱度

1回答

上佈置

在調試rxJava網絡電話在一個應用程序停止rxJava觀察到鏈執行我碰到這樣一種情況，如果我們dispose或clear處置對象由observables那麼只有第一observable鏈的訂閱返回得到處理而不是其他鏈接observables由flatMap。看一看下面的演示代碼片段： CompositeDisposable testCompositeDisposal = new Composi

1熱度

1回答

使用RxJava的狀態機？

我想全力以赴在RxJava和解決這個問題，我與它，但它似乎是很不適宜，因爲RxJava似乎不想處理有任何種類的狀態，而僅沿事件和傳遞改變它們來處理它們。的基本狀態機的行爲，我想用RxJava模仿是這樣的：在應用程序啓動事件，等待下一個應用程序暫停。在應用程序暫停事件，啓動一個15分鐘的計時器，並等待下一個應用程序的簡歷。如果應用程序在定時器中恢復，取消它，回到步驟1 在應用程序恢復事件，如

1熱度

1回答

切換線程中的Rx鏈多次

假設我有Android上下面的情況： 1）從網絡 2組的請求列表）顯示對於每個組的一些用戶界面元素爲每個組3）請求項 4）顯示UI elemets因爲我想做到這一點使用RxJava每個項目： webService.requestGroups() .flatMap(group -> { view.showGroup(group); return webSe

0熱度

2回答

在RXJava

與操作訂閱時如何處理異常下面是一個簡單的例子： Completable c = Completable.create(new CompletableOnSubscribe() { @Override public void subscribe(@NonNull CompletableEmitter e) throws Exception { throw new Ex

0熱度

1回答

將lambdas傳遞給kotlin中的Observable.subscribe會導致內存泄漏？

參見下面的科特林代碼： class MainActivity : AppCompatActivity() { override fun onCreate(savedInstanceState: Bundle?) { val disposable = Observable.interval(1, TimeUnit.SECONDS, AndroidSchedulers.main