how do I cancel a flow after the first time `colle...

# coroutines

[Andrew Ebling]

how do I cancel a flow after the first time collect { } completes? I’d like to do something like this, but the job val is not visible:

val eventJob = launch {
   myChannel
      .consumeAsFlow()
      .filterAllButFinalEvent()
      .collect { event ->
          doSomething()
          eventJob.cancel() // doesn’t compile
      }
   }

[Albert Chang]

Flow.first()

[Andrew Ebling]

ah - I see. So do I put that after .consumeAsFlow() or in place of it?

[Albert Chang]

launch {
    val firstEvent = yourFlow.first()
    doSomething()
}

[Albert Chang]

Or alternatively you can use Flow.take(1).collect().

[Andrew Ebling]

perfect - that’s done it. Many thanks @Albert Chang 👍