Android -рекурсивный вызов типа не вызван ⇐ Android

[Anonymous]

Я хочу сделать рекурсивный вызов, когда, если условие верно, как вы можете видеть внутри этого метода, но не работает. /> Итак, как это решить? Заранее спасибо.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.prepare(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!!)
}
}
< /code>
edit - минимальный пример < /p>
fun getWordsRequests(motherTongue: String,
foreignLanguage: String,
userId: String): 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)
}

override fun onDataChange(dataSnapshot: DataSnapshot) {
if (it > 0) {
for (ds in dataSnapshot.children) {
if (ds.child("user_id").value != userId) {
// ADDING TO LIST
}
}

if (list.size < 2 && list.size < it) {
getWordsRequests(motherTongue, foreignLanguage, userId)
}
}

trySend(list)
list.clear()
}
}

ref.orderByChild("id").startAt(lastWordRequest)
.limitToFirst(TOTAL_ELEMENTS_IN_LIST + 1)
.addListenerForSingleValueEvent(postListener)
}

awaitClose {
ref.orderByChild("id").startAt(lastWordRequest)
.limitToFirst(TOTAL_ELEMENTS_IN_LIST + 1)
.addListenerForSingleValueEvent(postListener!!)
}
}


Подробнее здесь: https://stackoverflow.com/questions/797 ... not-called