本頁(yè)展示的操作符用于對(duì)整個(gè)序列執(zhí)行算法操作或其它操作,由于這些操作必須等待數(shù)據(jù)發(fā)射完成(通常也必須緩存這些數(shù)據(jù)),它們對(duì)于非常長(zhǎng)或者無(wú)限的序列來(lái)說(shuō)是危險(xiǎn)的,不推薦使用。
rxjava-math
模塊的操作符averageInteger(?)
— 求序列平均數(shù)并發(fā)射averageLong(?)
— 求序列平均數(shù)并發(fā)射averageFloat(?)
— 求序列平均數(shù)并發(fā)射averageDouble(?)
— 求序列平均數(shù)并發(fā)射max(?)
— 求序列最大值并發(fā)射maxBy(?)
— 求最大key對(duì)應(yīng)的值并發(fā)射min(?)
— 求最小值并發(fā)射minBy(?)
— 求最小Key對(duì)應(yīng)的值并發(fā)射sumInteger(?)
— 求和并發(fā)射sumLong(?)
— 求和并發(fā)射sumFloat(?)
— 求和并發(fā)射sumDouble(?)
— 求和并發(fā)射concat(?)
— 順序連接多個(gè)Observablescount(?)
and countLong(?)
— 計(jì)算數(shù)據(jù)項(xiàng)的個(gè)數(shù)并發(fā)射結(jié)果reduce(?)
— 對(duì)序列使用reduce()函數(shù)并發(fā)射最終的結(jié)果collect(?)
— 將原始Observable發(fā)射的數(shù)據(jù)放到一個(gè)單一的可變的數(shù)據(jù)結(jié)構(gòu)中,然后返回一個(gè)發(fā)射這個(gè)數(shù)據(jù)結(jié)構(gòu)的ObservabletoList(?)
— 收集原始Observable發(fā)射的所有數(shù)據(jù)到一個(gè)列表,然后返回這個(gè)列表toSortedList(?)
— 收集原始Observable發(fā)射的所有數(shù)據(jù)到一個(gè)有序列表,然后返回這個(gè)列表toMap(?)
— 將序列數(shù)據(jù)轉(zhuǎn)換為一個(gè)Map,Map的key是根據(jù)一個(gè)函數(shù)計(jì)算的toMultiMap(?)
— 將序列數(shù)據(jù)轉(zhuǎn)換為一個(gè)列表,同時(shí)也是一個(gè)Map,Map的key是根據(jù)一個(gè)函數(shù)計(jì)算的