La collecte de Kotlin Flow est-elle uniquement de l'API interne kotlinx.coroutines?

Remplacer Collect par CollectLaSest .

La réponse est, non, Collect n'est pas seulement l'API interne Kotlinx.Coroutines. Le message d'erreur est trompeur.

Selon le commentaire de @ IR42, Ajouter l'importation de Kotlinx.Coroutines.flow.Collect Résoudre le problème.

Informations supplémentaires, pourquoi je n'a pas choisi collectionLaSest car la réponse

Collect et Collectlatest est différente.

En utilisant cet exemple

I'm not blocked 1
I'm not blocked 2
1
I'm not blocked 3
2

Collect produira

fun simple(): Flow<Int> = flow { // flow builder
    for (i in 1..3) {
        delay(100) // pretend we are doing something useful here
        emit(i) // emit next value
    }
}

fun main() = runBlocking<Unit> {
    // Launch a concurrent coroutine to check if the main thread is blocked
    launch {
        for (k in 1..3) {
            println("I'm not blocked $k")
            delay(100)
        }
    }
    // Collect the flow
    simple().collectLatest { value -> println(value) } 
}

selon https://kotlinlang.org/docs/reference/coroutines/flow.html

mais CollectlaSest

I'm not blocked 1
1
I'm not blocked 2
2
I'm not blocked 3
3

produira

fun simple(): Flow<Int> = flow { // flow builder
    for (i in 1..3) {
        delay(100) // pretend we are doing something useful here
        emit(i) // emit next value
    }
}

fun main() = runBlocking<Unit> {
    // Launch a concurrent coroutine to check if the main thread is blocked
    launch {
        for (k in 1..3) {
            println("I'm not blocked $k")
            delay(100)
        }
    }
    // Collect the flow
    simple().collect { value -> println(value) } 
}

Ajouter ci-dessous l'importation:

import kotlinx.coroutines.flow.collect

Pour la version 1.6.0-rc3 et plus récent:

les annotations @internalcoroutinesapi ont été supprimées de toutes les fonctions collection () 3 ne verra plus l'erreur et n'aura plus besoin de l'importation

import kotlinx.coroutines.flow.collect

car (avec les modifications de un autre pr ) Nous pouvons maintenant utiliser directement le collection () fonction membre.

p>

L'API a changé dans les versions plus récentes de Kotlinx Coroutines et au lieu d'un lambda dans la fonction de collecte, il devrait passer comme l'appel final de la chaîne. L'exemple de documentation:

flow
  .onEach { value -> process(value) }
  .catch { e -> handleException(e) }
  .collect() // trigger collection of the flow

J'ai finalement trouvé la solution pour cela après que cela m'a presque rendu fou. Comme aucune des solutions ici n'a fonctionné pour moi, j'avais un cas spécial où je travaillais sur un projet multi-modules et Collect () a continué à jeter cette erreur partout et même à l'importation manuelle ne l'a pas répandue.

Résolution du problème pour moi est explicitement ajouté de la dépendance aux coroutines à tous les modules de mon projet build.grads fichiers, pas seulement celui de l'application, même les modules qui n'utilisent pas les coroutines.