目錄

【Koltin Flow（一）】五種創(chuàng)建flow的方式
【Koltin Flow（二）】Flow操作符之末端操作符
【Koltin Flow（三）】Flow操作符之中間操作符（一）
【Koltin Flow（三）】Flow操作符之中間操作符（二）
【Koltin Flow（三）】Flow操作符之中間操作符（三）

前言

1. flow 是序列的異步版本，這是一種收集類型，其中的值是逐個生成的。與序列一樣，只有需要某個值時，flow 才會根據(jù)需要生成該值，而且 flow 可以包含無限數(shù)量的值。
2. 簡單來說就是流式處理，用過Rx的會比較容易理解。
3. flow通過api和協(xié)程支持，處理響應式編程更方便。

創(chuàng)建方式

創(chuàng)建方式1 flow{}

代碼如下

        flow {
              repeat(10){
                    delay(10)
                    emit(it)
                }
            }.collect {
                Log.d(TAG.TAG,"method 1 it is $it")
            }

日志如下：

2022-07-28 17:05:01.070 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 0
2022-07-28 17:05:01.080 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 1
2022-07-28 17:05:01.091 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 2
2022-07-28 17:05:01.106 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 3
2022-07-28 17:05:01.130 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 4
2022-07-28 17:05:01.140 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 5
2022-07-28 17:05:01.153 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 6
2022-07-28 17:05:01.163 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 7
2022-07-28 17:05:01.174 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 8
2022-07-28 17:05:01.186 3699-3724/edu.test.demo D/Test-TAG: method 1 it is 9

創(chuàng)建方式2 flowof

代碼如下

            flowOf(1,2,3,4,5).collect {
                Log.d(TAG.TAG,"method 2 it is $it")
            }

日志如下：

2022-07-28 17:05:01.187 3699-3724/edu.test.demo D/Test-TAG: method 2 it is 1
2022-07-28 17:05:01.187 3699-3724/edu.test.demo D/Test-TAG: method 2 it is 2
2022-07-28 17:05:01.187 3699-3724/edu.test.demo D/Test-TAG: method 2 it is 3
2022-07-28 17:05:01.187 3699-3724/edu.test.demo D/Test-TAG: method 2 it is 4
2022-07-28 17:05:01.187 3699-3724/edu.test.demo D/Test-TAG: method 2 it is 5

創(chuàng)建方式3 asFlow

代碼如下

    listOf(6,7,8,9,10).asFlow().collect {
                Log.d(TAG.TAG,"method 3 it is $it")
            }

日志如下：

2022-07-28 17:05:01.204 3699-3724/edu.test.demo D/Test-TAG: method 3 it is 6
2022-07-28 17:05:01.204 3699-3724/edu.test.demo D/Test-TAG: method 3 it is 7
2022-07-28 17:05:01.204 3699-3724/edu.test.demo D/Test-TAG: method 3 it is 8
2022-07-28 17:05:01.204 3699-3724/edu.test.demo D/Test-TAG: method 3 it is 9
2022-07-28 17:05:01.204 3699-3724/edu.test.demo D/Test-TAG: method 3 it is 10

創(chuàng)建方式4 channelFlow{}

代碼如下

    channelFlow {
                repeat(10){
                    delay(10)
                    send(it)
                }
            }.collect {
                Log.d(TAG.TAG,"method 4 it is $it")
            }

日志如下：

2022-07-28 17:05:01.227 3699-3724/edu.test.demo D/Test-TAG: method 4 it is 0
2022-07-28 17:05:01.238 3699-3724/edu.test.demo D/Test-TAG: method 4 it is 1
2022-07-28 17:05:01.250 3699-3724/edu.test.demo D/Test-TAG: method 4 it is 2
2022-07-28 17:05:01.260 3699-3724/edu.test.demo D/Test-TAG: method 4 it is 3
2022-07-28 17:05:01.272 3699-3725/edu.test.demo D/Test-TAG: method 4 it is 4
2022-07-28 17:05:01.284 3699-3725/edu.test.demo D/Test-TAG: method 4 it is 5
2022-07-28 17:05:01.295 3699-3725/edu.test.demo D/Test-TAG: method 4 it is 6
2022-07-28 17:05:01.306 3699-3725/edu.test.demo D/Test-TAG: method 4 it is 7
2022-07-28 17:05:01.317 3699-3725/edu.test.demo D/Test-TAG: method 4 it is 8
2022-07-28 17:05:01.329 3699-3724/edu.test.demo D/Test-TAG: method 4 it is 9

創(chuàng)建方式5 callbackFlow{}

代碼如下

 callbackFlow<String> {
                delay(100)
                trySendBlocking("123456")
                awaitClose {  }
            }.collect {
                Log.d(TAG.TAG,"method 5 it is $it")
            }

日志如下：

2022-07-28 17:05:01.438 3699-3724/edu.test.demo D/Test-TAG: method 5 it is 123456

總結

本篇主要介紹flow的基礎創(chuàng)建部分，介紹了五種方式，因為內(nèi)容比較簡單，介紹比較少，直接上代碼也比較好理解。