Я хочу сделать рекурсивный вызов, когда, если условие верно, как вы можете видеть внутри этого метода, но не работает. class = "Lang-Kotlin PrettyPrint-Override">fun getWordsRequests(motherTongue: String,
foreignLanguage: String,
userId: String,
isNextPortion: Boolean,
isToShowPb: MutableLiveData): Flow =
callbackFlow {
val ref = database.getReference("words_requests").child(motherTongue)
.child(foreignLanguage)
var postListener: ValueEventListener? = null
getWordsRequestsCount(motherTongue, foreignLanguage, userId).collect {
postListener = object : ValueEventListener {
val list = ArrayList()
override fun onCancelled(error: DatabaseError) {
trySend(list)
isToShowPb.value = false
}
override fun onDataChange(dataSnapshot: DataSnapshot) {
if (it > 0) {
for (ds in dataSnapshot.children) {
if (ds.child("user_id").value != userId) {
val word = Word.prepareAssociation(ds, motherTongue, foreignLanguage)
val wordLoader = WordLoader(word)
list.add(wordLoader)
val isMore = Util.isMoreForMore(it, list.size)
wordLoader.isMore = isMore
val index = list.indexOf(wordLoader)
list[index] = wordLoader
}
}
isToShowPb.value = false
if (list.size < 2 && list.size < it) {
lastWordRequest += list.size
getWordsRequests(motherTongue, foreignLanguage, userId, isNextPortion, isToShowPb)
}
}
if (list.isNotEmpty()) {
val newLastAddingId = list.last().word.id!!.toDouble()
lastWordRequest = if (newLastAddingId > lastWordRequest) newLastAddingId else lastWordRequest
}
trySend(list)
list.clear()
}
}
if (isNextPortion) {
lastWordRequest++
}
ref.orderByChild("id").startAt(lastWordRequest)
.limitToFirst(TOTAL_ELEMENTS_IN_LIST + 1)
.addListenerForSingleValueEvent(postListener)
if (it == 0) {
clearValues()
isToShowPb.value = false
}
}
awaitClose {
ref.orderByChild("id").startAt(lastWordRequest)
.limitToFirst(TOTAL_ELEMENTS_IN_LIST + 1)
.addListenerForSingleValueEvent(postListener!!)
}
}
Подробнее здесь: https://stackoverflow.com/questions/797 ... not-called
