Доброго времени суток!
нужна помощь: есть extension function представленная на скриншоте и такая extension function:
inline fun unitFlow(crossinline block: suspend () -> Unit) = flow { emit(block()) }
я хочу реализовать следующий код:
launch {
unitFlow {
repeat(2){
captureCallbackFlow(file, executor)
.flatMapConcat{
//нужные действия
}.collect{
//нужные действия
}
}
}.collect{
//действие по завершению
}
}
проблема в том, что код срабатывает всего 1 раз, может кто-то объяснить, почему