flowOf(1, 2, 3).map { it * 2 } // Produces 2, 4, 6
2、 filter:
过滤流中的元素,仅保留满足特定条件的元素。...(1, 2, 3).scan(0) { acc, value -> acc + value } // Produces 0, 1, 3, 6
过滤操作符
1、 filterNot:
过滤流中的元素,仅保留不满足特定条件的元素...flow {
emit(1)
emit(2)
}.buffer().collect { println(it) } // Prints 1, 2
2、 conflate:
仅保留最后一个未处理的值...emit(1)
emit(2)
emit(3)
}.conflate().collect { println(it) } // Prints 3
3、 collectLatest:
当新值产生时...才发射该元素。