RxJava轉換操作符window

2021-07-10 04:38:31 字數 1776 閱讀 1906

window操作符會在時間間隔內快取結果,類似於buffer快取乙個list集合,區別在於window將這個結果集合封裝成了observable

window(longtimespan, timeunit unit)
第乙個是快取的間隔時間,第二個引數是時間單位

});結果:

02-27 11:26:38.750 5279-5539/com.rxandroid.test1 d/----->: ------->onnext()

02-27 11:26:39.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():0

02-27 11:26:40.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():1

02-27 11:26:41.760 5279-5539/com.rxandroid.test1 d/----->: ------->onnext()

02-27 11:26:41.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():2

02-27 11:26:42.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():3

02-27 11:26:43.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():4

02-27 11:26:44.760 5279-5539/com.rxandroid.test1 d/----->: ------->onnext()

02-27 11:26:44.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():5

02-27 11:26:45.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():6

02-27 11:26:46.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():7

02-27 11:26:47.760 5279-5539/com.rxandroid.test1 d/----->: ------->onnext()

02-27 11:26:47.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():8

02-27 11:26:48.760 5279-5539/com.rxandroid.test1 d/----->: ------>call():9

02-27 11:26:48.760 5279-5539/com.rxandroid.test1 d/----->: ------>oncompleted()

RxJava 轉換操作符groupBy

groupby操作符顧名思義就是分組的意思 第一步 構造分組 call的返回值決定了組名 observable.range 0,10 groupby new func1 第二部 訂閱分組詳情 subscribe new observer override public void onerror th...

RxJava筆記 RxJava操作符

用來建立observable。public static observablecreate onsubscribef 把其他型別的物件和資料型別轉化成observable。observable.just 123 把其他型別的物件和資料型別轉化成observable。與just區別在與引數返回值不同 ...

RxJava操作符學習

操作符學習推薦閱讀 官方英文 翻譯中文 先來看乙個簡單的例子 被觀察者 observable.onsubscribeintegeronsubscribe new observable.onsubscribe 觀察者 subscriberintegersubscriber new subscriber...