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

collect

is a suspending function….

onFooEmission

must be suspending as well… or create a Coroutine inside

onFooEmission

and call

collect

from that Coroutine

My apologies,

onFooEmission

is a

CoroutineScope

extension and

fooFlow()

is a

suspend

You’d still need to call

launch

first, though…

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

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)
        }
    }
}

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

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.