本頁(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ì)算的