10 个有用的 Kotlin flow 操作符

Kotlin 拥有函数式编程的能力，运用得当，可以简化代码，层次清晰，利于阅读，用过都说好。

然而操作符数量众多，根据使用场景选择合适的操作符是一个很大的难题，网上搜索了许久只是学习了一个操作符，还要再去验证它，实在浪费时间，开发效率低下。

一种方式是转至命令式开发，将过程按步骤实现，即可完成需求；另一种方式便是一次学习多个操作符，在下次选择操作符时，增加更多选择。

本篇文章当然关注的是后者，列举一些比较常用 Kotlin 操作符，为提高效率助力，文中有图有代码有讲解，文末有参考资料和一个交互式学习的网站。

让我们开始吧。

1. reduce

reduce 操作符可以将所有数据累加（加减乘除）得到一个结果

listOf(1, 2, 3).reduce { a, b ->

    a + b

}


输出：6

如果 flow 中没有数据，将抛出异常。如不希望抛异常，可使用 reduceOrNull 方法。

reduce 操作符不能变换数据类型。比如，Int 集合的结果不能转换成 String 结果。

2. fold

fold 和 reduce 很类似，但是 fold 可以变换数据类型

有时候，我们不需要一个结果值，而是需要继续操 flow，可使用 runningFold 。

flowOf(1, 2, 3).runningFold("a") { a, b ->

    a + b

}.collect {

    println(it)

}


输出：

a

a1

a12

a123

同样的，reduce 也有类似的方法 runningReduce

flowOf(1, 2, 3).runningReduce { a, b ->

    a + b

}.collect {

    println(it)

}


输出：

1

3

6

3. debounce

debounce 需要传递一个毫秒值参数，功能是：只有达到指定时间后才发出数据，最后一个数据一定会发出。

例如，定义 1000 毫秒，也就是 1 秒，被观察者发出数据，1秒后，观察者收到数据，如果 1 秒内多次发出数据，则重置计算时间。

flow {

    emit(1)

    delay(590)

    emit(2)

    delay(590)

    emit(3)

    delay(1010)

    emit(4)

    delay(1010)

}.debounce(

    1000

).collect {

    println(it)

}


输出结果：

3

4

rebounce 的应用场景是限流功能

4. sample

sample 和 debounce 很像，功能是：在规定时间内，只发送一个数据

flow {

    repeat(4) {

        emit(it)

        delay(50)

    }

}.sample(100).collect {

    println(it)

}


输出结果：

1

3

sample 的应用场景是截流功能

debounce 和 sample 的限流和截流功能已有网友实现，点击这里

5. flatmapMerge

简单的说就是获得两个 flow 的乘积或全排列，合并并且平铺，发出一个 flow。

描述的仍然不好理解，一看代码便能理解了

flowOf(1, 3).flatMapMerge {

    flowOf("$it a", "$it b")

}.collect {

    println(it)

}


输出结果：

1 a

1 b

3 a

3 b

flatmapMerge 还有一个特性，在下一个操作符里提及。

6. flatmapConcat

先看代码。

flowOf(1, 3).flatMapConcat {

    flowOf("a", "b", "c")

}.collect {

    println(it)

}

功能和 flatmapMerge 一致，不同的是 flatmapMerge 可以设置并发量，可以理解为 flatmapMerge 是线程安全的，而 flatmapConcat 不是线程安全的。

本质上，在 flatmapMerge 的并发参数设置为 1 时，和 flatmapConcat 基本一致，而并发参数大于 1 时，采用 channel 的方式发出数据，具体内容请参阅源码。

7. buffer

介绍 buffer 的时候，先要看这样一段代码。

flowOf("A", "B", "C", "D")

.onEach {

    println("1 $it")

}

.collect { println("2 $it") }


输出结果：

1 A

2 A

1 B

2 B

1 C

2 C

1 D

2 D

注意输出的内容。

加上 buffer 的代码。

flowOf("A", "B", "C", "D")

.onEach {

    println("1 $it")

}

.buffer()

.collect { println("2 $it") }


输出结果：

1 A

1 B

1 C

1 D

2 A

2 B

2 C

2 D

输出内容有所不同，buffer 操作符可以改变收发顺序，像有一个容器作为缓冲似的，在容器满了或结束时，下游开始接到数据，onEach 添加延迟，效果更明显。

8. combine

合并两个 flow，长的一方会持续接受到短的一方的最后一个数据，直到结束

flowOf(1, 3).combine(

    flowOf("a", "b", "c")

) { a, b -> b + a }

.collect {

    println(it)

}


输出结果：

a1

b3

c3

9. zip

也是合并两个 flow，结果长度与短的 flow 一致，很像木桶原理。 

flowOf(1, 3).zip(

    flowOf("a", "b", "c")

) { a, b -> b + a }

.collect {

    println(it)

}


输出结果：

a1

b3

10. distinctUntilChanged

就像方法名写的那样，和前一个数据不同，才能收到，和前一个数据想通，会被过滤掉。

flowOf(1, 1, 2, 2, 3, 1).distinctUntilChanged().collect {

    println(it)

}


输出结果：

1

2

3

1

最后

以上就是今天要介绍的操作符，希望对大家有所帮助。

参考文章：Android — 9 Useful Kotlin Flow Operators You Need to Know

Kotlin 交互式操作符网站：交互式操作符网站