注册

10 个有用的 Kotlin flow 操作符

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

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

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

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

让我们开始吧。

1. reduce

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

Kotlin_操作符.002.jpeg

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

输出:6

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

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

2. fold

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

Kotlin_操作符.003.jpeg

有时候,我们不需要一个结果值,而是需要继续操 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 需要传递一个毫秒值参数,功能是:只有达到指定时间后才发出数据,最后一个数据一定会发出

Kotlin_操作符.004.jpeg

例如,定义 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 很像,功能是:在规定时间内,只发送一个数据

Kotlin_操作符.005.jpeg

flow {
repeat(4) {
emit(it)
delay(50)
}
}.sample(100).collect {
println(it)
}

输出结果:
1
3

sample 的应用场景是截流功能

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

5. flatmapMerge

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

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

Kotlin_操作符.006.jpeg

flowOf(1, 3).flatMapMerge {
flowOf("$it a", "$it b")
}.collect {
println(it)
}

输出结果:
1 a
1 b
3 a
3 b

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

6. flatmapConcat

先看代码。

Kotlin_操作符.007.jpeg

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,长的一方会持续接受到短的一方的最后一个数据,直到结束

Kotlin_操作符.008.jpeg

flowOf(1, 3).combine(
flowOf("a", "b", "c")
) { a, b -> b + a }
.collect {
println(it)
}

输出结果:
a1
b3
c3

9. zip

也是合并两个 flow,结果长度与短的 flow 一致,很像木桶原理。 Kotlin_操作符.009.jpeg

flowOf(1, 3).zip(
flowOf("a", "b", "c")
) { a, b -> b + a }
.collect {
println(it)
}

输出结果:
a1
b3

10. distinctUntilChanged

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

Kotlin_操作符.010.jpeg

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 交互式操作符网站:交互式操作符网站


作者:亢龙有悔
链接:https://juejin.cn/post/7135013334059122719
来源:稀土掘金
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

0 个评论

要回复文章请先登录注册