如何从扫描的BLE结果中创建列表

Question

作为在此处提出的问题的倒置如何将Flow＆lt; list＆lt; object; ; object＆gt; 我想将我的flow＆lt; object＆gt;转换为flow flow＆lt; list＆lt; object＆gt;＆gt;＆gt;。

至少我认为我想要那个，所以我尝试解释我想实现的目标并提供一些背景。我正在研究使用蓝牙扫描并连接到BLE设备的Android应用程序。我是Android平台和Kotlin的新手，因此尽管我已经学到了很多东西，但我并没有完全掌握所有细节。

我的存储库有一种方法，该方法可以从蓝牙适配器中返回一系列扫描仪：

fun bluetoothScan(): Flow<ScanResult> {
    return bluetoothStack.bluetoothScan()
}

我的ViewModel会消耗该功能，将数据映射到我的BlescanResult中，并将其返回为Livedata。

val scanResults: LiveData<BleScanResult> =
    scanEnabled.flatMapLatest { doScan ->
        if (doScan) {
            repository.bluetoothScan().map { BleScanResult(it.device.name, it.device.address) }
        } else {
            emptyFlow()
        }
    }.asLiveData()

在我的活动中，我想观察该数据并在recyclerview中显示：

val adapter = ScanResultListAdapter()
binding.rcBleScanResults.adapter = adapter

viewModel.scanResults.observe(this) { result ->
    //result.let { adapter.submitList(it) }
}

问题是scanresults来自类型flow＆lt; blescanresult＆gt;，而不是flow lt＆lt; list＆lt; blescanresult＆gt;＆gt;，因此呼叫adapter.submitlist（it）将错误作为 it 预计为列表。

那么，如何将Flow转换为flow＆lt; list＆gt;（使用重复的其他过滤）？还是我想念流/寿命的概念？

Answer 1

您可以尝试使用mutablelist并用您获得的数据填充flow，类似以下内容：

val results: MutableList<BleScanResult> = mutableListOf()
val scanResults: LiveData<List<BleScanResult>> =
    scanEnabled.flatMapLatest { doScan ->
        if (doScan) {
            repository.bluetoothScan().map { 
                results.apply { 
                    add(BleScanResult(it.device.name, it.device.address)) 
                } 
            }
        } else {
            emptyFlow()
        }
    }.asLiveData()

您还可以使用mutableset而不是mutablelist如果要拥有一个唯一的项目列表（假设blescanresult是data class）。

Answer 2

您可以使用livedata构建器将流的值收集到mutablelist中。

在这里，我使用TOLIST（）在发射它之前复制Mutablelist，因为RecyClerview适配器在可变数据源方面效果不佳。

val scanResults: LiveData<List<BleScanResult>> = liveData {
    val cumulativeResults = mutableListOf<BleScanResult>()

    scanEnabled.flatMapLatest { doScan ->
        if (doScan) {
            repository.bluetoothScan().map { BleScanResult(it.device.name, it.device.address) }
        } else {
            emptyFlow()
        }
    }.collect {
        cumulativeResults += it
        emit(cumulativeResults.toList())
    }
}

如果要避免重复条目并重新排序条目，则可以使用这样的集合：

val scanResults: LiveData<List<BleScanResult>> = liveData {
    val cumulativeResults = mutableSetOf<BleScanResult>()

    scanEnabled.flatMapLatest { doScan ->
        if (doScan) {
            repository.bluetoothScan().map { BleScanResult(it.device.name, it.device.address) }
        } else {
            emptyFlow()
        }
    }.collect {
        if (it !in cumulativeResults) {
            cumulativeResults += it
            emit(cumulativeResults.toList())
        }
    }
}