NetworkOnMainThreadException при запуске сопрограмм через `Dispatchers.IO` - PullRequest
Новая
       58

NetworkOnMainThreadException при запуске сопрограмм через `Dispatchers.IO`

0 голосов
/ 23 апреля 2019

Я пытаюсь сделать базовый сетевой вызов, используя шаблон View / ViewModel / UseCase / Repository. Основной асинхронный вызов выполняется через сопрограммы, которые запускаются с использованием Dispatchers.IO.

Для начала вот соответствующий код:

ViewModel: 

class ContactHistoryViewModel @Inject constructor(private val useCase: GetContactHistory) : BaseViewModel() {
    // ...
    fun getContactHistory(userId: Long, contactId: Long) {
        useCase(GetContactHistory.Params(userId, contactId)) { it.either(::onFailure, ::onSuccess) }
    }
}

GetContactHistory UseCase: 

class GetContactHistory @Inject constructor(private val repository: ContactRepository) : UseCase<ContactHistory, GetContactHistory.Params>() {

    override suspend fun run(params: Params) = repository.getContactHistory(params.userId, params.contactId)
    data class Params(val userId: Long, val contactId: Long)
}

Базовый класс UseCase, использованный выше: 

abstract class UseCase<out Type, in Params> where Type : Any {

    abstract suspend fun run(params: Params): Either<Failure, Type>

    operator fun invoke(params: Params, onResult: (Either<Failure, Type>) -> Unit = {}) {
        val job = GlobalScope.async(Dispatchers.IO) { run(params) }
        GlobalScope.launch(Dispatchers.IO) { onResult(job.await()) }
    }
}

Наконец, хранилище: 

class ContactDataRepository(...) : SyncableDataRepository<ContactDetailDomainModel>(cloudStore.get(), localStore),
        ContactRepository {

    override fun getContactHistory(userId: Long, contactId: Long): Either<Failure, ContactHistory> {
        return request(cloudStore.get().getContactHistory(userId, contactId), {it}, ContactHistory(null, null))
    }

    /**
     * Executes the request.
     * @param call the API call to execute.
     * @param transform a function to transform the response.
     * @param default the value returned by default.
     */
    private fun <T, R> request(call: Call<T>, transform: (T) -> R, default: T): Either<Failure, R> {
        return try {
            val response = call.execute()
            when (response.isSuccessful) {
                true -> Either.Right(transform((response.body() ?: default)))
                false -> Either.Left(Failure.GenericFailure())
            }
        } catch (exception: Throwable) {
            Either.Left(Failure.GenericFailure())
        }
    }
}

Резюме: Помещение точки останова отладки в этот блок catch{} в хранилище (видно выше) показывает, что выбрасывается android.os.NetworkOnMainThreadException. Это странно, учитывая, что обе сопрограммы запускаются с контекстом Dispatchers.IO, а не Dispatchers.Main (основной поток пользовательского интерфейса Android).

Вопрос: Почему выбрасывается указанное выше исключение и как можно исправить этот код?

Ответы [ 2 ]

0 голосов
/ 23 апреля 2019

Проблема в том, что вы нигде не создаете сопрограмму.Для этого вы можете использовать функцию высшего порядка suspendCoroutine.Простой пример будет выглядеть так: 

private suspend fun <T, R> request(call: Call<T>, transform: (T) -> R, default: T): Either<Failure, R> {
        return suspendCoroutine { continuation ->
            continuation.resume(try {
                val response = call.execute()
                when (response.isSuccessful) {
                    true -> Either.Right(transform((response.body() ?: default)))
                    false -> Either.Left(Failure.GenericFailure())
                }
            } catch (exception: Throwable) {
                Either.Left(Failure.GenericFailure())
            })
        }
    }

Есть много способов, с помощью которых вы тоже можете пойти с этим.Обратите внимание, что эта функция никогда не выдаст исключение.Я думаю, что это задумано, но если вы хотите распространить его вверх, чтобы иметь возможность обернуть его, например, в блок try-catch, вы можете использовать continuation.resumeWithException(...).

Поскольку эта функция возвращает фактическую сопрограмму, вашwithContext(Dispatchers.IO) должно работать как задумано.Надеюсь, это поможет!

0 голосов
/ 23 апреля 2019

Маркировка функции suspend не делает ее приостановленной, вы должны убедиться, что работа действительно выполняется в фоновом потоке.

У вас есть 

override suspend fun run(params: Params) = repository.getContactHistory(params.userId, params.contactId)

, которая вызывает это 

override fun getContactHistory(userId: Long, contactId: Long): Either<Failure, ContactHistory> {
    return request(cloudStore.get().getContactHistory(userId, contactId), {it}, ContactHistory(null, null))
}

Все они синхронные, ваш модификатор suspend здесь ничего не делает.

Быстрое решение проблемы - изменить ваш репозиторий следующим образом 

override suspend fun getContactHistory(userId: Long, contactId: Long): Either<Failure, ContactHistory> {
return withContext(Dispatchers.IO) {
    request(cloudStore.get().getContactHistory(userId, contactId), {it}, ContactHistory(null, null))
    }
}

Но гораздо лучшим решением было бы использовать адаптер Coroutine для Retrofit.

...