rx-java2

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

0熱度

1回答

RxJava構成了可觀察的基礎上的條件裏面emmited項目

我不知道我是正確的措辭措辭，這是我在做什麼：下載圖像（如果需要）應用一些效果（模糊），並將其設置爲設備壁紙： data class SetWallpaperIntent(val bitmap : Bitmap?, val url : String) setWallpaperObservable.switchMap { setWallpaperIntent -> if (setWall

0熱度

1回答

Rxjava鏈條不止一個請求

我是RxJava的新概念。我想鏈的一些電話： Observable<RoomList> listRoomsCall = mRoomServiceApi.listRooms(); //這個調用會讓我RoomIds 下一步就是要求所有RoomIds - 請求後要求 mMeetingServiceApi.listMeetings(roomID, startsAtString, endsAtStri

0熱度

1回答

成本在RxJava線程切換和科特林數據類副本（）操作

我的問題是關於特定操作的成本科特林數據類copy()操作和RxJavaobserveOn()線程切換的成本。我有一個系統產生事件，比如說Schedulers.mainThread。事件是Kotlin數據類別。接下來是業務邏輯，最後，鏈條產生新的數據類別通過copy()操作。所有結果必須在Schedulers.mainThread上消耗。因此，鏈看起來就像是： eventSource() //Ev

0熱度

1回答

當stream2基於stream1時，如何避免.zip（stream1，stream2，BiFun）兩次訂閱stream1？

我在android中使用firebase和一些複雜的數據。我需要保存引用，並且遇到了zip操作的問題，或者我處理RX的方式。我想創建一個新的A object關於某種B信息，並更新我的B object有信息關於創建A。當火力業務均出現了成功，我將返回Single<A> val singleA = firebaseCall(A("ABC", bKey)) val singleB = single

0熱度

1回答

RxJava而不是改造回調

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

0熱度

1回答

永遠的Mockito（）不andThen工作rxjava2

我正在測試一個相當簡單的一件寫在科特林代碼： o1.updateUser(params) .andThen(o2.reload()) 當UpdateUser兩個失敗，我想到的是重載不會被執行。但是當使用Mockito 2和jUnit 5進行測試時，就會調用這個模擬。嘲諷就是這樣完成的： given(o1.updateUser(user)).willReturn(Completabl

1熱度

1回答

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

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

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