Используя produce
, вы вводите область действия для своего канала.Это означает, что код, который производит элементы, которые передаются по каналу, может быть отменен.
Это также означает, что время жизни вашего Канала начинается в начале лямбды produce
и заканчивается, когда заканчивается эта лямбда.
В вашем примере лямбда вашего produce
вызов почти сразу заканчивается, что означает, что ваш канал закрыт почти сразу.
Измените ваш код на что-то вроде этого:
fun CoroutineScope.startScan(filters: List<ScanFilter>, settings: ScanSettings = defaultSettings): ReceiveChannel<ScanResult?> = produce {
scanCallback = object : ScanCallback() {
override fun onScanResult(callbackType: Int, result: ScanResult) {
offer(result)
}
}
scanner.startScan(filters, settings, scanCallback)
// now suspend this lambda forever (until its scope is canceled)
suspendCancellableCoroutine<Nothing> { cont ->
cont.invokeOnCancellation {
scanner.stopScan(...)
}
}
}
...
val channel = scope.startScan(filter)
...
...
scope.cancel() // cancels the channel and stops the scanner.
Я добавил строку suspendCancellableCoroutine<Nothing> { ... }
, чтобы сделать его приостановленным 'навсегда '.
Обновление: использование produce
и обработка ошибок структурированным способом (допускает структурированный параллелизм):
fun CoroutineScope.startScan(filters: List<ScanFilter>, settings: ScanSettings = defaultSettings): ReceiveChannel<ScanResult?> = produce {
// Suspend this lambda forever (until its scope is canceled)
suspendCancellableCoroutine<Nothing> { cont ->
val scanCallback = object : ScanCallback() {
override fun onScanResult(callbackType: Int, result: ScanResult) {
offer(result)
}
override fun onScanFailed(errorCode: Int) {
cont.resumeWithException(MyScanException(errorCode))
}
}
scanner.startScan(filters, settings, scanCallback)
cont.invokeOnCancellation {
scanner.stopScan(...)
}
}
}