0

Есть функция:

fun DatabaseReference.takeAll(): Any {

    this.addValueEventListener(object : ValueEventListener {

        override fun onDataChange(snapshot: DataSnapshot) {
            if (snapshot.exists()) {
                val counter = snapshot.childrenCount
                if (counter > 1) {
                    val list: MutableList<String>? = null
                    for (i in snapshot.children) {
                        list?.add(i.key.toString())
                    }
                } else if (counter == 1L) {
                    val data = snapshot.value.toString()
                }
            } else {
                Log.e(TAG, "Take All Function: snapshot is not exist")
            }
        }

        override fun onCancelled(error: DatabaseError) {
            Log.e(TAG, error.message)
        }

    })

}

Её задача — достать данные из БД по определенному пути и вернуть мне их.

У меня несколько вопросов:

  1. Что писать как возвращаемое значение, т. к. оно может быть и списком и просто строкой.

  2. Как в конце функции вернуть значение только когда данные полностью загрузятся, чтобы после вызова я их записал и пошел дальше работать.

Пробовал вернуть в for или в else if, но ругается на то, что функция onDataChange должна возвращать Unit. При попытке вернуть не Unit ругается на override, что предсказуемо.

Запускается функция из main-потока, но можно реализовать её как корутину. Вызывать я планирую её примерно вот так:

val data = путь.takeAll()

И дальше какие то действия с ней.

6
  • Функция takeAll не может вам вернуть данные, так как она лишь занимается тем, что регистрирует некоторый EventListener, который отложенно в будущем вызовет (а может и никогда не вызовет) метод onDataChange. Поэтому "здесь и сейчас" takeAll вам ничего не вернет. 14 авг 2021 в 18:04
  • @Vadik, хорошо, а как лучше эту задачу реализовать? 14 авг 2021 в 18:12
  • Вероятно, вам нужно использовать единоразовое чтение из базы. А регистрация слушателя позволяет читать данные непрерывно. 14 авг 2021 в 19:07
  • 1
    @Vadik, единоразовое чтение у FB тоже асинхронное, так что автор попадет в тот же капкан "вернуть синхронно результат асинхронного вызова." 14 авг 2021 в 19:45
  • @ДмитрийКолесник нужно больше контекста, откуда вы вызываете эту функцию? Из какого потока? Если из main-потока, то его блокировка приведет к "зависанию" вашего приложения, поэтому синхронно вернуть данные из базы категорически плохо. Что используете для многопоточности в вашем приложении, м. б. rxjava или корутины? Отредактируйте вопрос, добавьте подробностей. 15 авг 2021 в 13:18

1 ответ 1

0

По документации Firebase, чтобы единоразово вытащить данные из базы, нужно выполнить следующий код:

database.child("users").child(userId).get()
    .addOnSuccessListener { data ->
        println("Пользователь: ${data.value}")
    }
    .addOnFailureListener { exception ->
        println("Не удалось получить пользователя из базы")
        exception.printStackTrace()
    }

Для удобной интеграции Tasks API с корутинами есть расширение kotlinx-coroutines-play-services. Экстеншен await() упростит работу с отложенными Task. Тот же самый код будет выглядеть так:

try {
    val data = database.child("users").child(userId).get().await()
    println("Пользователь: ${data.value}")
} catch (exception: Exception) {
    println("Не удалось получить пользователя из базы")
    exception.printStackTrace()
}

Экстеншен await() является suspend-функцией, поэтому может быть вызван только из другой suspend-функции либо из корутины.

2
  • Здравствуйте, не очень понимаю в чем проблема. Пытаюсь написать такую функцию: ` fun DatabaseReference.t(){ CoroutineScope(Dispatchers.IO).launch { try{ [email protected]("").get().await() }catch (e: Exception){ } } } ` Но ругается на await() говорит что такой функции нет нет. 16 авг 2021 в 10:36
  • Подключите kotlinx-coroutines-play-services в ваш проект. 16 авг 2021 в 10:55

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.