rx-java

0熱度

1回答

我正在使用MVVM與Rxjava，這是我第一次使用Rxjava，我想通過Spinner中的響應填充項目。但我無法這樣做。 spinner如何動態填充？ ApiInterface @GET("client") Observable<List<ClientListApi>> clientListApi(); RegisterFragmentVm public void getClient

0熱度

2回答

RxJava和一些編碼與rxjava它讓你想在一個完全不同的方式，我仍然無法理解我應該怎麼做時，我想要一些操作的一些數據保存在集合中（後收藏

保存數據可以說地圖的一個關鍵的價值），以便在所有請求完成後稍後處理。例如可以說我想發出一些對某個API的調用，並在地圖中保存所有失敗的調用響應，以便稍後進行一些「錯誤更正」。直到現在它看起來像我需要從上到下寫整個流程來做這個請求 - >錯誤 - >糾正這是一個操作管道，我想分離到兩個不同的操作發生在不同的時間。我意識到我可能錯過了rxjava的一個關鍵概念。總之我怎麼之外緩存數據的集合在以

0熱度

2回答

如何緩存RxJava/RxScala中的observable

我有一個REST API，它使用基於RxScala的反應式scala驅動程序來調用mongodb。在我的API控制器或服務層，我需要用緩存來避免通話使用hazelcast（或任何其他緩存工具）我所有的服務都是異步，只返回觀察到的，任何想法如何，我可以給的MongoDB用可觀察的方式實現緩存？

1熱度

2回答

如何找到配置文件的內存泄漏

我已經拋棄了大量的內存，並發現存在內存泄漏。如果你看截圖，你會看到只有一個片段，但有9個相同類型的演示者。應該只有一個。當我檢查一個演示者實例時，分析器向我顯示對演示者的引用。這些都是RxAndroid方法的回調方法。我正確地取消了在片段的onDestroyView中的所有這些。不過，演示者實例並未被清理（如您所見）。所以我想知道如何區分有效（循環，內部）引用，它仍然存在，因爲對象仍然沒有垃圾

1熱度

1回答

如何刷新改進2/rxJava中的ACCESS-TOKEN

我發出請求（任何授權，註冊等），然後我發現我需要更新ACCESS-TOKEN，即得到錯誤401。這裏是授權請求： BaseApplication.getApiClient() .signIn(accessToken, body) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.main

0熱度

1回答

RxJava而不是改造回調

我是新來使用RxJava和我有問題，我怎麼能改變我的新回調從RxJava的改造？我的工作代碼是在這裏： Service service = new Retrofit.Builder() .baseUrl("lalala") .addConverterFactory(GsonConverterFactory.create()) .build()

1熱度

1回答

如何合併2個獨立的數據流，從他們緩衝填充的數據和時間

一些大寫金額我想測試像這樣的情況後subsrcibe它：我有2類新剛剛從同一個延伸。我創建，並從項目的每個班級列表觀測量： val listSomeClass1 = ArrayList<SomeClass1>() val listSomeClass2 = ArrayList<SomeClass2>() fun populateJust1() { listSomeClass1.a

3熱度

2回答

RxJava zipWith使用Android Studio 3.0在Kotlin中的IDE錯誤

我想創建一個Observable，它發出一些來自Observable和Observable的包含Interval Observable的對象列表，以便來自第一個可觀察對象的項目將以一定的時間延遲發射。這是我實現： val just1 = ArrayList<SomeClass1>() 填充某些項目 fun populateJust1() { just1.add(SomeClass1("23

1熱度

1回答

如何模擬發射2 infiite Observable流，並有其他Observable每10秒合併它們並緩衝？

我想能夠模擬合併兩個單獨的流，它們發出一些對象（即擴展相同的父對象），使用緩衝區操作符緩衝它們並在10秒後發出收集的數據。我希望這種機制是無限的，這種合併/緩衝區總是在來自2個分離的流的排放時被調用。以下是我迄今所做的： val list1 = mutableListOf<SomeClass1>( SomeClass1("1", 1), SomeClass1("2", 2), Som

1熱度

1回答

如何創建無限的時間間隔Observable每隔一段時間就會發射一個新的Object？

我想創建一個Observable，它會每秒發射一個新對象。所以現在我只是用一個間隔Observable壓縮一個Observable，它從列表中發出有限數量的對象。 val list1 = mutableListOf<SomeClass1>( SomeClass1("1", 1), SomeClass1("2", 2), SomeClass1("3", 3), SomeC