coroutines-con-kotlin.updates.sharedflow-06-collapsed.kt

val myRepository = MyRepository()
val myComponent = MyComponent(myRepository)
...
val job = launch {
    delay(1250)
    myComponent.mySharedFlow
        .onStart {
            log("Collector started collecting...")
        }
        .collect {
            log("Collected => $it")
            delay(600)
        }
}

val fetcher = myComponent.fetchAndEmitList()
fetcher.join()
myComponent.release()
delay(2500)

job.cancel()