Flow<Long> 与 Long 比较：如何处理异步数据流与原始值

Android

2024-03-06 20:29:29

Flow 与 Long 类型比较：深入解析

问题概要

在使用 Room 数据库的应用程序开发中，你可能需要比较 Flow<Long> 类型和 Long 类型的值。直接比较这两个类型是不可能的，因为 Flow<Long> 是一个异步数据流，而 Long 是一个原始值。

解决方法

要解决这个问题，需要将 Flow<Long> 中的数据收集起来。有两种方法可以实现：

使用 .first() 运算符： 返回流中的第一个值，等待流发出数据。
使用 .collect() 运算符： 将流中的所有值收集到一个列表或数组中。

步骤指南

1. 使用 .first() 运算符

val today = System.currentTimeMillis() // Long
val lastRecordFlow = viewModel.getLast() // Flow<Long>

lastRecordFlow.first().observe(this) { lastRecord ->
    // lastRecord 是一个 Long 类型的值
    // 现在可以比较 today 和 lastRecord
}

2. 使用 .collect() 运算符

val today = System.currentTimeMillis() // Long
val lastRecordFlow = viewModel.getLast() // Flow<Long>

lastRecordFlow.collect { lastRecord ->
    // lastRecord 是一个 Long 类型的值
    // 现在可以比较 today 和 lastRecord
}

示例代码

import kotlinx.coroutines.runBlocking

fun main() = runBlocking {
    val today = System.currentTimeMillis()
    val lastRecordFlow = viewModel.getLast()

    // 使用 .first() 运算符
    val lastRecord1 = lastRecordFlow.first()
    println("today: $today, lastRecord1: $lastRecord1")

    // 使用 .collect() 运算符
    val lastRecordList = mutableListOf<Long>()
    lastRecordFlow.collect { lastRecord ->
        lastRecordList.add(lastRecord)
    }
    println("today: $today, lastRecordList: $lastRecordList")
}