集合操作
集合操作将会把所有的元素塞进到集合中,或list或map,然后将整个集合作为一个item发送出去。
- toList
Observable.just("A", "B", "C").toList().subscribe { it -> println(it) }
Observable.range(0, 100).toList(30).subscribe { it ->
println("$it")
}
感觉是压缩操作
- toSortedList
能把各个item 压缩为list 并且对list 进行排序
Observable.just(122, 33, 22, 4, 1222, 4).toSortedList().subscribe { it -> println(it) }
- toMap
Observable.just("ADD", "DDD", "EEE", "DASDS").toMap { it[0] }.subscribe { it -> println(it) }