1. filter
-
描述: 返回一个只包含满足给定条件的值的流。
-
使用场景: 适用于需要根据条件筛选数据的情况。
val numbersFlow = flowOf(1, 2, 3, 4, 5)
val evenNumbersFlow = numbersFlow.filter { it % 2 == 0 }
// 使用
evenNumbersFlow.collect { println(it) } // 输出: 2, 4
2. filterNot
-
描述: 返回一个只包含不满足给定条件的值的流。
-
使用场景: 适用于需要排除特定数据的情况。
val notEvenNumbersFlow = numbersFlow.filterNot { it % 2 == 0 }
// 使用
notEvenNumbersFlow.collect { println(it) } // 输出: 1, 3, 5
3. filterIsInstance
-
描述: 返回一个只包含指定类型的值的流。
-
使用场景: 适用于需要从混合类型的流中筛选特定类型的情况。
val mixedFlow = flowOf(1, "two", 3, "four")
val stringsFlow = mixedFlow.filterIsInstance<String>()
// 使用
stringsFlow.collect { println(it) } // 输出: "two", "four"
4. filterIsInstance(klass: KClass<R>)
-
描述: 返回一个只包含给定类实例的值的流。
-
使用场景: 类似于
filterIsInstance，但允许动态类型检查。
val stringsFlowDynamic = mixedFlow.filterIsInstance(String::class)
// 使用
stringsFlowDynamic.collect { println(it) } // 输出: "two", "four"
5. filterNotNull
-
描述: 返回一个只包含非空值的流。
-
使用场景: 适用于需要排除 null 值的情况。
val nullableFlow = flowOf(1, null, 3, null, 5)
val nonNullFlow = nullableFlow.filterNotNull()
// 使用
nonNullFlow.collect { println(it) } // 输出: 1, 3, 5
6. map
-
描述: 返回一个应用给定转换函数后的新流。
-
使用场景: 适用于需要转换数据格式的情况。
val doubledFlow = numbersFlow.map { it * 2 }
// 使用
doubledFlow.collect { println(it) } // 输出: 2, 4, 6, 8, 10
7. mapNotNull
-
描述: 返回一个只包含非空转换结果的流。
-
使用场景: 适用于需要转换并排除 null 值的情况。
val transformedFlow = numbersFlow.mapNotNull { if (it % 2 == 0) it * 2 else null }
// 使用
transformedFlow.collect { println(it) } // 输出: 4, 8
8. withIndex
-
描述: 返回一个流，包含每个元素及其索引。
-
使用场景: 适用于需要跟踪元素索引的情况。
val indexedFlow = numbersFlow.withIndex()
// 使用
indexedFlow.collect { (index, value) -> println("Index: $index, Value: $value") }
// 输出: Index: 0, Value: 1; Index: 1, Value: 2; ...
9. onEach
-
描述: 在传递每个值之前执行给定操作的流。
-
使用场景: 适用于日志记录、UI 更新等副作用处理。
numbersFlow.onEach { println("Processing: $it") }
.collect() // 输出: Processing: 1; Processing: 2; ...
10. scan
-
描述: 使用给定操作对流进行折叠，返回每个中间结果。
-
使用场景: 适用于需要连续累加或聚合数据的情况。
val scannedFlow = numbersFlow.scan(0) { acc, value -> acc + value }
// 使用
scannedFlow.collect { println(it) } // 输出: 0, 1, 3, 6, 10, 15
11. runningFold
-
描述: 类似于
scan，但返回每个中间结果，初始值为给定的值。
-
使用场景: 适用于从初始值开始进行折叠的情况。
val runningFoldFlow = numbersFlow.runningFold(10) { acc, value -> acc + value }
// 使用
runningFoldFlow.collect { println(it) } // 输出: 10, 11, 13, 16, 20, 25
12. runningReduce
-
描述: 使用给定操作对流进行折叠，返回每个中间结果，第一个元素作为初始值。
-
使用场景: 适用于需要从第一个元素开始聚合的情况。
val runningReduceFlow = numbersFlow.runningReduce { acc, value -> acc + value }
// 使用
runningReduceFlow.collect { println(it) } // 输出: 1, 3, 6, 10, 15
13. chunked
-
描述: 将流拆分为不重叠的列表，每个列表的大小不超过给定的大小。
-
使用场景: 适用于需要将数据分组的情况。
val chunkedFlow = flowOf("a", "b", "c", "d", "e").chunked(2)
// 使用
chunkedFlow.collect { println(it) } // 输出: ["a", "b"], ["c", "d"], ["e"]
