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

class MyComponent(private val myRepository: MyRepository): CoroutineScope by CoroutineScope(Dispatchers.IO) {
  
    private val _mySharedFlow = MutableSharedFlow<Int>(2, 3, BufferOverflow.DROP_OLDEST)
    val mySharedFlow: SharedFlow<Int>
        get() = _mySharedFlow

    fun fetchAndEmitList() = launch {
        myRepository.getList().forEach {
            log("Emitting => $it")
            _mySharedFlow.emit(it)
            delay(250)
        }
    }

    fun release() {
        this.coroutineContext[Job]?.cancelChildren()
    }
}