Эта функция должна преобразовывать обычный flow во flow, значение которой обёрнуто в Result

toResultFlow.kt

 fun <T> Flow<T>.toResultFlow(): Flow<Result<T>> {
    return flow {
        while (true) {
            var fromDownstream = false
            try {
                collect {
                    try {
                        emit(Result.success(it))
                    } catch (e: Throwable) {
                        fromDownstream = true
                        throw e
                    }
                }
            } catch (e: Throwable) {
                if (fromDownstream) throw e
                emit(Result.failure(e)) // <-- проблема тут! после вызова этой функции запустится ещё одна итерация цикла
            }
        }
    }
}