我正在扫描一个列表，并在mutableList中添加一个唯一的项。通过ScanCallback扫描一个项，但下面的示例是使用Kotlin Flow以便更好地理解并制作一个简单的用例。我给出了一个发出不同类型项的示例。
基本上我想从特定条件中删除项目：-
1.当流数据结束时发出新值。
1.当发送一个项目时，如果我们在30秒内不再接收项目，那么我们从列表中删除该项目。

import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.collectLatest
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.runBlocking

class ItemList {
    val scanResultList = mutableListOf<ScanResults>()
    fun doSomething(): Flow<ScanResults> = flow {
       (0..20).forEach {
           delay(200L)
           when (it) {
             in 10..12 -> {
                 emit(ScanResults(Device("item is Adding in range of 10 -- 20")))
             }

             in 15..18 -> {
                 emit(ScanResults(Device("item is Adding in range of 15 -- 18")))
             }

             else -> {
                 emit(ScanResults(Device("item is Adding without range")))
             }
         }
     }
 }

 fun main() = runBlocking {
     doSomething().collectLatest { value ->
         handleScanResult(value)
     }
 }

 private fun handleScanResult(result: ScanResults) {
     if (!scanResultList.contains(result)) {
         result.device?.name?.let {
             if (hasNoDuplicateScanResult(scanResultList, result)) {
                 scanResultList.add(result)
                 println("Item added")
             }
         }
     }
 }

 private fun hasNoDuplicateScanResult(value: List<ScanResults>, result: ScanResults): Boolean {
     return value.count { it.device == result.device } < 1
 }

 data class ScanResults(val device: Device? = null)
 data class Device(val name: String? = null)
}

我没有添加Set，因为在SnapshotStateList中jetpack compose中不可用。