Kotlin сопрограммы resumeWithException error

Question

Я решил обернуть получение местоположения устройства (один раз, без обновления), используя kotlin coriutines, поэтому, наконец, я получил этот код:

@SuppressLint("MissingPermission")
suspend fun LocationManager.getCurrentLocationOnce(): Location {
    return suspendCancellableCoroutine { continuation ->
        try {
            val locationListener = object : SimpleLocationListener {
                override fun onLocationChanged(location: Location?) {
                    if (location == null) {
                        this@getCurrentLocationOnce.removeUpdates(this)
                        continuation.resumeWithException(FailedToRetrieveLocationException("Location is NULL"))
                    } else {
                        this@getCurrentLocationOnce.removeUpdates(this)
                        continuation.resume(location)
                    }
                }

                override fun onProviderEnabled(provider: String?) {}

                override fun onProviderDisabled(provider: String?) {
                    this@getCurrentLocationOnce.removeUpdates(this)
                    continuation.resumeWithException(ProviderDisabledException(provider ?: ""))
                }

            }

            this.requestSingleUpdate(
                LocationManager.GPS_PROVIDER,
                locationListener,
                null
            )
        } catch (e : Exception) {
            continuation.resumeWithException(e)
        }
    }
}

Когда GPS включен, все работает нормально, но когда GPS включен Программа OFF не работает с исключением ProviderDisabledException, это из-за:

override fun onProviderDisabled(provider: String?) {
                    this@getCurrentLocationOnce.removeUpdates(this)
                    continuation.resumeWithException(ProviderDisabledException(provider ?: ""))
                }

Но я не знаю, почему это не удается, потому что на месте, где я использую эту функцию, у меня есть:

try {
            val locationManager = (requireActivity().getSystemService(Context.LOCATION_SERVICE) as? LocationManager)
                ?: throw FailedToRetrieveLocationException("Location Service is null")
            val location = locationManager.getCurrentLocationOnce()
            log("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle",
                "Successfully got location={lat:${location.latitude}, long:${location.longitude}}")
            downloadRestaurantsWithLocation(location)
        } catch (ex : FailedToRetrieveLocationException) {
            logError("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle", ex)
            throw ex
        } catch (providerException : ProviderDisabledException) {
            logError("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle", providerException)
            throw providerException
        } catch (e : Exception) {
            logError("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle", e)
            throw e
        }

Итак, я регистрирую исключение и повторно бросаю его в функцию вызывающего абонента, а в функции вызывающего абонента я ловлю это исключение:

            try {
                    log("[GOOGLE] downloadRestaurants", "Starting donwload restaurants for GOOGLE")
                    downloadRestaurantsWithGPSLocationGoogle()
                } catch (e : Exception) {
                    logError("[GOOGLE] error happened while getting location", e)
                    downloadRestaurantsWithFusedLocationGoogle()
                }

И в трассировке стека ошибок у меня есть только это:

E/[GOOGLE] downloadRestaurantsWithGPSLocationGoogle: my.package.location.exceptions.ProviderDisabledException: Provider gps disabled
        at my.package.common.location.LocationUtilsKt$getCurrentLocationOnce$$inlined$suspendCancellableCoroutine$lambda$1.onProviderDisabled(LocationUtils.kt:45)
        at android.location.LocationManager$ListenerTransport._handleMessage(LocationManager.java:384)
        at android.location.LocationManager$ListenerTransport.access$000(LocationManager.java:300)
        at android.location.LocationManager$ListenerTransport$1.handleMessage(LocationManager.java:316)
        at android.os.Handler.dispatchMessage(Handler.java:106)
        at android.os.Looper.loop(Looper.java:207)
        at android.app.ActivityThread.main(ActivityThread.java:6878)
        at java.lang.reflect.Method.invoke(Native Method)
        at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:547)
        at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:876)

Я не знаю, почему приложение не работает, потому что такой код работает идеально:

lifecycleScope.launch {
    try {
        throwError()
    } catch (e : Exception) {
        e.printStackTrace()
    }
}

private suspend fun throwError() {
    return suspendCancellableCoroutine { continuation ->
        continuation.resumeWithException(ProviderDisabledException("TEST"))
    }
}

Answer 1

Итак, наконец-то я понял, почему это sh приложение =). Все в порядке с сопрограммами.

Проблема в этом методе:

@Throws(ProviderDisabledException::class, FailedToRetrieveLocationException::class)
private fun downloadRestaurantsWithGPSLocationGoogle() = lifecycleScope.launch {
    log("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle", "Trying to get location via GPS")
    try {
        val locationManager = (requireActivity().getSystemService(Context.LOCATION_SERVICE) as? LocationManager)
            ?: throw FailedToRetrieveLocationException("Location Service is null")
        val location = locationManager.getCurrentLocationOnce()
        log("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle",
            "Successfully got location={lat:${location.latitude}, long:${location.longitude}}")
        downloadRestaurantsWithLocation(location)
    } catch (ex : FailedToRetrieveLocationException) {
        ex.printStackTrace()
        logError("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle", ex)
        throw ex
    } catch (providerException : ProviderDisabledException) {
        providerException.printStackTrace()
        logError("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle", providerException)
        throw providerException
    } catch (e : Exception) {
        e.printStackTrace()
        logError("[GOOGLE] downloadRestaurantsWithGPSLocationGoogle", e)
        throw e
    }
}

И проблема в том, что я генерирую исключение из сопрограммы и обрабатываю это исключение не в сопрограмме, поэтому я запустил свою сопрограмму, и все try-cathces пропущены, потому что здесь я использую стиль огонь и забыл. Поэтому, чтобы исправить это, мне нужно приостановить этот метод и выбросить исключения. Место, где пытаются отловить ошибки:

private fun downloadRestaurants() = lifecycleScope.launch {
        log("downloadRestaurantsWithLocationSort",
            "Requesting Manifest.permission.ACCESS_COARSE_LOCATION & Manifest.permission.ACCESS_FINE_LOCATION permissions")
        val user = requestPermissions(
            Manifest.permission.ACCESS_COARSE_LOCATION,
            Manifest.permission.ACCESS_FINE_LOCATION
        )
        if (!user.any { !it.second }) {
            // permission is granted, can download restaurants and sort by nearest
            log("downloadRestaurantsWithLocationSort", "Permissions is granted")
            log("MANUFACTURER", Build.MANUFACTURER)
            if (Build.MANUFACTURER == "Huawei" || Build.MANUFACTURER == "HUAWEI") {
                showToast("HUAWEI")
                try {
                    log("[HUAWEI] downloadRestaurants", "Starting donwload restaurants for HUAWEI")
                    downloadRestaurantsWithGPSLocationHuawei()
                } catch (e : Exception) { // this will not work, because FIRE and FORGET
                    e.printStackTrace()
                    logError("[HUAWEI] error happened while getting location", e)
                    mainViewModel.downloadRestaurantsHeaders(null)
                }
            } else {
                showToast("NOT A HUAWEI")
                try {
                    log("[GOOGLE] downloadRestaurants", "Starting donwload restaurants for GOOGLE")
                    downloadRestaurantsWithGPSLocationGoogle()
                } catch (e : Exception) { // this will not work, because FIRE and FORGET
                    e.printStackTrace()
                    logError("[GOOGLE] error happened while getting location", e)
                    downloadRestaurantsWithFusedLocationGoogle()
                }
            }
        } else {
            // permission is not granted, just download the restaurants
            log("downloadRestaurantsWithLocationSort", "Permissions is NOT granted")
            mainViewModel.downloadRestaurantsHeaders(null)
        }
    }

Итак, ответ заставляет функции downloadRestaurantsWithGPSLocationGoogle и downloadRestaurantsWithFusedLocationGoogle приостанавливаться и не запускать внутри них отдельные сопрограммы. (удалить lifecycleScope.launch)