未在异步函数中调用 Kotlin 回调

Question

我正在尝试在 Android API 28 中订阅 BLE 外围设备的多个特性。

由于 BLE API 的异步特性，我需要制作订阅每个特征 (gatt.writeDescriptor()) 块的函数；否则 BLE API 将尝试一次订阅多个特征，尽管一次只能写入一个描述符：这意味着只能订阅一个特征。

阻塞是通过重写onServicesDiscovered回调并调用异步函数来循环和订阅特征来实现的。这被一个简单的布尔值 (canContinue) 阻止。 很遗憾，回调函数onDescriptorWrite从未被调用过。

请看下面的代码：

override fun onDescriptorWrite(gatt: BluetoothGatt, descriptor: BluetoothGattDescriptor, status: Int) {
    canContinue = true 
} 

override fun onServicesDiscovered(gatt: BluetoothGatt, status: Int) { 
    runBlocking {
        loopAsync(gatt)
    }
}

private suspend fun loopAsync(gatt: BluetoothGatt) {
    coroutineScope {
        async {
            gatt.services.forEach { gattService ->                      
                gattService.characteristics.forEach { gattChar ->
                    CHAR_LIST.forEach {
                        if (gattChar.uuid.toString().contains(it)) {
                            canContinue = false
                            gatt.setCharacteristicNotification(gattChar, true)

                            val descriptor = gattChar.getDescriptor(UUID.fromString(BleNamesResolver.CLIENT_CHARACTERISTIC_CONFIG))                                     
                            descriptor.value = BluetoothGattDescriptor.ENABLE_NOTIFICATION_VALUE

                            val write = Runnable {
                                gatt.writeDescriptor(descriptor)
                            }
                            //private val mainHandler = Handler(Looper.getMainLooper())
                            //mainHandler.post(write)
                            //runOnUiThread(write)
                            gatt.writeDescriptor(descriptor)

                        }

                        while (!canContinue)
                    }
                }
            }
        }
    }
}

在 related post 中建议我在主线程中运行 gatt.writeDescriptor() 函数。正如您在上面的代码中看到的那样，我尝试使用 runOnUiThread() 并根据 this 问题的建议创建一个 Handler 对象均无济于事。

如果我从同步函数调用gatt.writeDescriptor()，回调会被调用，我不知道为什么它不会从异步函数调用。

编辑：看来while(!canContinue); 循环实际上阻塞了回调。如果我将此行注释掉，回调就会触发，但我会面临与以前相同的问题。怎么屏蔽这个功能？

欢迎提出任何建议！原谅我的无知，但我已经非常习惯于在嵌入式系统上工作，Android 对我来说是一个非常新的世界！

谢谢， 亚当

Answer 1

我在 cmets 中发布了一些注释，但我认为将其格式化为答案会更好。

即使您已经解决了问题，我还是建议您异步运行实际的协程并在其中等待使用 channels 的写入通知

private var channel: Channel<Boolean> = Channel()

override fun onDescriptorWrite(gatt: BluetoothGatt, descriptor: BluetoothGattDescriptor, status: Int) {
    GlobalScope.async {
        channel.send(true)
    }
} 

override fun onServicesDiscovered(gatt: BluetoothGatt, status: Int) { 
    GlobalScope.async {
        loopAsync(gatt)
    }
}

private suspend fun loopAsync(gatt: BluetoothGatt) {
    gatt.services.forEach { gattService ->                      
        gattService.characteristics.forEach { gattChar ->
            CHAR_LIST.forEach {
                if (gattChar.uuid.toString().contains(it)) {
                    gatt.setCharacteristicNotification(gattChar, true)

                    val descriptor = gattChar.getDescriptor(UUID.fromString(BleNamesResolver.CLIENT_CHARACTERISTIC_CONFIG))                                     
                    descriptor.value = BluetoothGattDescriptor.ENABLE_NOTIFICATION_VALUE

                    gatt.writeDescriptor(descriptor)
                    channel.receive()
                }
            }
        }
    }
}

Answer 2

所以我实际上自己想出了答案。

while(!canContinue); 循环实际上阻塞了回调，因为它在主线程中运行，并优先于设置 canContinue 变量所需的回调。

这可以通过在主线程中调用gatt.writeDescriptor() 函数和while 循环来解决：

val subscribe = Runnable {
    gatt.writeDescriptor(descriptor)
    while (!canContinue);
    }

runOnUiThread(subscribe)