I have the following: ```suspend fun fooFlow(): Fl...

# coroutines

[rook]

I have the following:

suspend fun fooFlow(): Flow<List<Foo>>
fun CoroutineScope.onFooEmission(action: (List<Foo>) -> Unit) {
  launch {
    fooFlow().collect { foos -> action(foos) }
  }
}

But at the collect call-site, I’m getting

Type mismatch.
Required: FlowCollector<List<Foo>>
Found: (Nothing) -> Unit

[streetsofboston]

collect is a suspending function…. onFooEmission must be suspending as well… or create a Coroutine inside onFooEmission and call collect from that Coroutine

[rook]

My apologies, onFooEmission is a CoroutineScope extension and fooFlow() is a suspend

[streetsofboston]

You’d still need to call launch first, though…

[streetsofboston]

fun CoroutineScope.onFooEmission(action: (List<Foo>) -> Unit) {
  launch { fooFlow().collect { foos -> action(foos) } }
}

[rook]

You’re right, I accidentally omitted a bunch of things. But that still doesn’t resolve my issue

[rook]

I still have the same error with everything you outlined above

[streetsofboston]

It works fine in Android Studio:

fun fooFlow(): Flow<List<Foo>> = TODO()

fun CoroutineScope.onFooEmission(action: (List<Foo>) -> Unit) {
    launch {
        fooFlow().collect { foos ->
            action(foos)
        }
    }
}

[streetsofboston]

Be sure to import kotlinx.coroutines.flow.collect, though!

[rook]

Looks like my auto-import just completely failed. Manually importing the dependency worked just fine. Thanks!

[David Glasser]

Yeah, getting extension functions to auto-import when they have the same name as interface functions is a big pain. I guess this is why star imports exist, though my team tries to avoid them.