//NOTE: 下面的示例是錯(cuò)誤寫(xiě)法
  lifecycleScope.launch { 
        mFlowModel.caseFlow1
            .flowWithLifecycle(lifecycle, Lifecycle.State.STARTED)
            .collect {}

        mFlowModel.caseFlow2
            .flowWithLifecycle(lifecycle, Lifecycle.State.STARTED)
            .collect {}
  }

  lifecycleScope.launch {
        launch {
            mFlowModel.caseFlow1
                .flowWithLifecycle(lifecycle, Lifecycle.State.STARTED)
                .collect {}
       }

        launch {
            mFlowModel.caseFlow2
                .flowWithLifecycle(lifecycle, Lifecycle.State.STARTED)
                .collect {}
        }
    }

// assets目錄下person.json
{
	"name": "小馬快跑",
	"age": 18,
	"interest": "money! lots of money!"
}

/**
 * 通過(guò)Flow方式，獲取本地文件
 */
 private fun getFileInfo() {
      lifecycleScope.launch {
            flow {
                //解析本地json文件，并生成對(duì)應(yīng)字符串
                val configStr = getAssetJsonInfo(requireContext(), "person.json")
                //最后將得到的實(shí)體類(lèi)發(fā)送到下游
                emit(configStr)
            }
                .map { json ->
                    Gson().fromJson(json, PersonModel::class.java) //通過(guò)Gson將字符串轉(zhuǎn)為實(shí)體類(lèi)
                }
                .flowOn(Dispatchers.IO) //在flowOn之上的所有操作都是在IO線程中進(jìn)行的
                .onStart { log("onStart") }
                .filterNotNull()
                .onCompletion { log("onCompletion") }
                .catch { ex -> log("catch:${ex.message}") }
                .collect {
                    log("collect parse result:$it")
                }
        }
  }

/**
 * 讀取Assets下的json文件
 */
private fun getAssetJsonInfo(context: Context, fileName: String): String {
        val strBuilder = StringBuilder()
        var input: InputStream? = null
        var inputReader: InputStreamReader? = null
        var reader: BufferedReader? = null
        try {
            input = context.assets.open(fileName, AssetManager.ACCESS_BUFFER)
            inputReader = InputStreamReader(input, StandardCharsets.UTF_8)
            reader = BufferedReader(inputReader)
            var line: String?
            while ((reader.readLine().also { line = it }) != null) {
                strBuilder.append(line)
            }
        } catch (ex: Exception) {
            ex.printStackTrace()
        } finally {
            try {
                input?.close()
                inputReader?.close()
                reader?.close()
            } catch (e: IOException) {
                e.printStackTrace()
            }
        }
    return strBuilder.toString()
}

lifecycleScope.launch {
     lifecycle.repeatOnLifecycle(Lifecycle.State.STARTED) {
                 //將兩個(gè)flow串聯(lián)起來(lái) 先搜索目的地，然后到達(dá)目的地
                mFlowModel.getSearchFlow()
                    .flatMapConcat {
                        //第二個(gè)flow依賴第一個(gè)的結(jié)果
                        mFlowModel.goDestinationFlow(it)
                    }.collect {
                        mTvCallbackFlow.text = it ?: "error"
                    }
     }
}

  //ViewModel中
  //分別請(qǐng)求電費(fèi)、水費(fèi)、網(wǎng)費(fèi)，F(xiàn)low之間是并行關(guān)系
  suspend fun requestElectricCost(): Flow<ExpendModel> =
        flow {
            delay(500)
            emit(ExpendModel("電費(fèi)", 10f, 500))
        }.flowOn(Dispatchers.IO)

  suspend fun requestWaterCost(): Flow<ExpendModel> =
        flow {
            delay(1000)
            emit(ExpendModel("水費(fèi)", 20f, 1000))
        }.flowOn(Dispatchers.IO)

  suspend fun requestInternetCost(): Flow<ExpendModel> =
        flow {
            delay(2000)
            emit(ExpendModel("網(wǎng)費(fèi)", 30f, 2000))
        }.flowOn(Dispatchers.IO)

  data class ExpendModel(val type: String, val cost: Float, val apiTime: Int) {
    fun info(): String {
        return "${type}: ${cost}, 接口請(qǐng)求耗時(shí)約$apiTime ms"
    }
}

    //UI層
    mBtnZip.setOnClickListener {
        lifecycleScope.launch {
            val electricFlow = mFlowModel.requestElectricCost()
            val waterFlow = mFlowModel.requestWaterCost()
            val internetFlow = mFlowModel.requestInternetCost()

            val builder = StringBuilder()
            var totalCost = 0f
            val startTime = System.currentTimeMillis()
            //NOTE:注意這里可以多個(gè)zip操作符來(lái)合并Flow，且多個(gè)Flow之間是并行關(guān)系
            electricFlow.zip(waterFlow) { electric, water ->
                totalCost = electric.cost + water.cost
                builder.append("${electric.info()},\n").append("${water.info()},\n")
            }.zip(internetFlow) { two, internet ->
                totalCost += internet.cost
                two.append(internet.info()).append(",\n\n總花費(fèi)：$totalCost")
            }.collect {
                mTvZipResult.text = it.append("，總耗時(shí)：${System.currentTimeMillis() - startTime} ms")
            }
        }
    }