Блог

Я написал этот фрагмент кода для загрузки файлов изображений из хранилища firebase в локальное хранилище.

 contentResolver.openOutputStream(uri)?.use { ops ->   // *
    Firebase.storage.getReferenceFromUrl(model.mediaUrl).stream.await().stream.use { ips ->
        val buffer = ByteArray(1024)
        while (true) {
            val bytes = ips.read(buffer)   // *
            if (bytes == -1)
                break
            ops.write(buffer, 0, bytes)   // *
        }
    }
}
 

В отмеченных строках android studio выдает мне Inappropriate blocking method call предупреждение, выделяя функции openOutputStream(), read() и write(). Я запускал код несколько раз, и он работал правильно. Весь этот фрагмент кода находится внутри функции приостановки, вызываемой из сопрограммы ввода-вывода.
Кто-нибудь, пожалуйста, подскажите мне действительную причину и способы устранения этого предупреждения.

Редактировать Этот код вызывается в следующем контексте.

 fun someFunc() {
    lifecycleScope.launch(IO) {
        val uri = getUri(model)
        ...
    }
    ...
}
...
suspend fun getUri(model: Message): Uri {
    ... // Retrive the image file using mediastore.
    if ( imageNotFound ) return downloadImage(model)
    else return foundUri
}
suspend fun downloadImage(model: Message): Uri {
    ... // Create contentvalues for new image.
    val uri = contentResolver.insert(collectionUri, values)!!
    // Above mentioned code snippet is here.
    return uri
}
 

Правильно составленная функция приостановки никогда не блокируется. Он не должен зависеть от того, вызывается ли он из определенного диспетчера, а скорее должен явно переносить блокирующий код в соответствующий диспетчер.

Таким образом , части вашей функции приостановки , которые вызывают блокирующий код , должны быть обернуты withContext(Dispatchers.IO){} . Тогда сопрограмме, которая его вызывает, даже не нужно указывать диспетчера. Это делает его очень удобным lifecycleScope для вызова функций и обновления пользовательского интерфейса и позволяет не беспокоиться о диспетчерах.

Пример:

 suspend fun foo(file: File) {
    val lines: List<String> = withContext(Dispatchers.iO) {
        file.readLines()
    }
    println("The file has ${lines.size} lines.")
}