sample-channel-events.kt

@Composable
fun <T>ObserveEffects(
    flow: Flow<T>,
    key1: Any? = null,
    key2: Any? = null,
    onEvent: suspend (T) -> Unit
) {
    val lifecycleOwner = LocalLifecycleOwner.current


    LaunchedEffect(flow, lifecycleOwner, key1, key2) {
        lifecycleOwner.repeatOnLifecycle(Lifecycle.State.STARTED) {
            withContext(Dispatchers.Main.immediate){
                flow.collect {
                    onEvent(it)
                }
            }
        }
    }
}


example usage:


@Composable
fun WelcomeScreenRoot(
    viewModel: WelcomeViewModel = koinViewModel(),
    onNavigate: (LoginGroupNavType) -> Unit
) {
    ObserveEffects(viewModel.events) { effect ->
        when (effect) {
            is WelcomeEffect.Navigate -> {
                onNavigate(effect.route)
            }
        }
    }


    WelcomeScreen(
            state = viewModel.state,
            onIntent = viewModel::onAction
        )
}