如何解决将广播接收器包装成 Flow协程
我有一个用于 wifi 扫描结果的广播接收器作为数据源,我想以协程方式制作它。我在这里找到了暂停功能的答案: https://stackoverflow.com/a/53520496/5938671
suspend fun getCurrentScanResult(): List<ScanResult> =
suspendCancellableCoroutine { cont ->
//define broadcast reciever
val wifiScanReceiver = object : BroadcastReceiver() {
override fun onReceive(c: Context,intent: Intent) {
if (intent.action?.equals(WifiManager.SCAN_RESULTS_AVAILABLE_ACTION) == true) {
context.unregisterReceiver(this)
cont.resume(wifiManager.scanResults)
}
}
}
//setup cancellation action on the continuation
cont.invokeOnCancellation {
context.unregisterReceiver(wifiScanReceiver)
}
//register broadcast reciever
context.registerReceiver(wifiScanReceiver,IntentFilter(WifiManager.SCAN_RESULTS_AVAILABLE_ACTION))
//kick off scanning to eventually receive the broadcast
wifiManager.startScan()
}
这对于信号发射很好,但是如果我想在扫描过程中获得结果,那么我会崩溃,因为 cont.resume()
只能被调用一次。然后我决定尝试Flow
。这是我的代码:
suspend fun getCurrentScanResult(): Flow<List<ScanResult>> =
flow{
val wifiScanReceiver = object : BroadcastReceiver() {
override fun onReceive(c: Context,intent: Intent) {
if (intent.action?.equals(WifiManager.SCAN_RESULTS_AVAILABLE_ACTION) == true) {
//context.unregisterReceiver(this)
emit(wifiManager.scanResults)
}
}
}
//setup cancellation action on the continuation
//register broadcast reciever
context.registerReceiver(wifiScanReceiver,IntentFilter(WifiManager.SCAN_RESULTS_AVAILABLE_ACTION))
//kick off scanning to eventually receive the broadcast
wifiManager.startScan()
}
但现在 Android Stuidio 说 Suspension functions can be called only within coroutine body
for function emit(wifiManager.scanResults)
有没有办法在这里使用 Flow?
解决方法
请查看专为此用例设计的 callback flow。像这样的事情可以完成这项工作:
callbackFlow {
val receiver = object : BroadcastReceiver() {
override fun onReceive(context: Context?,intent: Intent) {
if (intent.action == WifiManager.SCAN_RESULTS_AVAILABLE_ACTION) {
sendBlocking(wifiManager.scanResults) // or non-blocking offer()
}
}
}
context.registerReceiver(receiver,intentFilter)
awaitClose {
context.unregisterReceiver(receiver)
}
}
您可能还想与例如共享此流程shareIn 操作符以避免为每个流订阅者注册一个新的接收者。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。