Блог

Я разрабатываю приложение для Android.

Я использую Retrofit2 и сопрограмму для извлечения некоторых данных из моего Rest API.

Когда в моем Rest API возникает исключение, оно возвращает код исключения и сообщение об исключении с HTTP status = 4xx или 5xx, как показано на скриншоте ниже

Если ответ является исключением, я сопоставляю код исключения и ExceptionMessage с ответом в моем приложении для Android в соответствии с приведенным ниже кодом.

 val exceptionBody = Gson().fromJson(response.errorBody()?.string(), ExceptionResponse::class.java)
  

Это ExceptionResponse класс

 data class ExceptionResponse(
    val exceptionCode: String,
    val exceptionMessage: String
)
  

Вот проблема. Когда я это делаю response.errorBody()?.string() , Android Studio выдает мне предупреждение о «неправильном вызове метода блокировки»

Вот мой repository вызов сетевого вызова

 override fun fetchData() {
    CoroutineScope(Dispatchers.IO).launch {
        val fetchedData = myRemoteDataSource.fetchData()
    }
}
  

Вот MyRemoteDataSource класс

 class MyRemoteDataSourceImpl(
    private val myAPIService: MyAPIService
): BaseRemoteDataSource(), MyRemoteDataSource {

    override suspend fun fetchData(): Resource<List<Data>> {
        return getResult {
            myAPIService.fetchData()
        }
    }
}
  

И вот мой BaseRemoteDataSource класс, который имеет getResult() where errorBody.string вызывается

Как вы можете видеть на скриншоте выше, единственная сопрограмма, которая не выдает мне предупреждение, является последней

 GlobalScope.launch(Dispatchers.IO) {
    Gson().fromJson(response.errorBody()?.string(), ExceptionResponse::class.java)
}
  

Итак, у меня есть несколько вопросов об этом предупреждении и сопрограммировании

1. Почему последний не выдает мне предупреждение, но все остальные области сопрограммы?

 GlobalScope.launch(Dispatchers.IO) {
    Gson().fromJson(response.errorBody()?.string(), ExceptionResponse::class.java)
}
  

2. Похоже, мне нужен структурированный параллелизм, потому что мне нужно проанализировать JSON и вернуть его. Если я CoroutineScope или GlobalScope тогда я верну null, если я не использую scope.join . Тогда не следует ли мне использовать CoroutineScope(), который использует область сопрограммы родительского / вызывающего объекта для структурированного параллелизма?

3. Похоже, что response.errorBody()?.string() анализирует JSON, который должен быть в диспетчерах.По умолчанию, не так ли? Просто для справки, я включаю исходный код для string()

   public final String string() throws IOException {
    try (BufferedSource source = source()) {
      Charset charset = Util.bomAwareCharset(source, charset());
      return source.readString(charset);
    }
  }
  

4. Можно ли использовать последний, потому что тогда я создаю GlobalScope в CoroutineScope.

5. использует ли withContext() область сопрограммы вызывающего абонента точно так же, как CoroutineScope(), или он создает новую область с разными диспетчерами?

Извините, что сразу сбрасываю вопросы, но все они связаны. Спасибо, ребята!!!

Нормально вызывать блокировку выполнения в IO контексте, потому что он предназначен для выполнения таких задач. Поэтому, я думаю, лучший способ — написать функцию расширения ResponseBody для того, чтобы сделать это в соответствующем IO контексте. Однако в этой функции также появляется предупреждение, но, поскольку мы знаем, что мы хорошо с этим справились, мы можем его подавить.

 @Suppress("BlockingMethodInNonBlockingContext")
suspend fun ResponseBody.stringSuspending() =
    withContext(Dispatchers.IO) { string() }
  

Поэтому мы уверены, что ResponseBody.string() это будет выполнено в IO контексте, независимо от того, что оно может быть обернуто другим контекстом:

 Gson().fromJson(response.errorBody()?.stringSuspending(), ExceptionResponse::class.java)